1 Star 1 Fork 4

liangxn / flinkStreamSQL

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
克隆/下载
mysqlSink.md 1.05 KB
一键复制 编辑 原始数据 按行查看 历史
simenliuxing 提交于 2019-11-11 15:54 . readme format

1.格式:

CREATE TABLE tableName(
    colName colType,
    ...
    colNameX colType
 )WITH(
    type ='mysql',
    url ='jdbcUrl',
    userName ='userName',
    password ='pwd',
    tableName ='tableName',
    parallelism ='parllNum'
 );

2.支持版本

mysql-5.6.35

3.表结构定义

参数名称 含义
tableName mysql表名称
colName 列名称
colType 列类型 colType支持的类型

4.参数:

参数名称 含义 是否必填 默认值
type 表名 输出表类型[mysq|hbase|elasticsearch]
url 连接mysql数据库 jdbcUrl
userName mysql连接用户名
password mysql连接密码
tableName mysql表名称
parallelism 并行度设置 1

5.样例:

CREATE TABLE MyResult(
    channel VARCHAR,
    pv VARCHAR
 )WITH(
    type ='mysql',
    url ='jdbc:mysql://172.16.8.104:3306/test?charset=utf8',
    userName ='dtstack',
    password ='abc123',
    tableName ='pv2',
    parallelism ='1'
 )
1
https://gitee.com/liangxianning/flinkStreamSQL.git
git@gitee.com:liangxianning/flinkStreamSQL.git
liangxianning
flinkStreamSQL
flinkStreamSQL
master

搜索帮助