@@ -22,7 +22,7 @@ CREATE TABLE tableName(
2222
2323| 参数名称| 含义|
2424| ----| ---|
25- | tableName| mysql表名称 |
25+ | tableName| 结果表名称 |
2626| colName | 列名称|
2727| colType | 列类型 [ colType支持的类型] ( docs/colType.md ) |
2828
@@ -33,21 +33,70 @@ CREATE TABLE tableName(
3333| type | 表名 输出表类型[ mysq| ; hbase| ; elasticsearch] | 是||
3434| url | 连接mysql数据库 jdbcUrl | 是||
3535| userName | mysql连接用户名 | 是||
36- | password | mysql连接密码| 是||
37- | tableName | mysql表名称| 是||
38- | parallelism | 并行度设置| 否| 1|
39-
40- ## 5.样例:
36+ | password | mysql连接密码| 是||
37+ | tableName | mysql表名称| 是||
38+ | parallelism | 并行度设置| 否| 1|
39+ | batchNum | flush的大小| 否| 100|
40+ | batchWaitInterval | flush的时间间隔,单位ms| 否| 1000|
41+ | allReplace| true:新值替换旧值| 否| false|
42+ | updateMode| APPEND:不回撤数据,只下发增量数据,UPSERT:先删除回撤数据,然后更新| 否||
43+
44+ ## 5.完整样例:
4145```
46+ CREATE TABLE MyTable(
47+ id int,
48+ channel varchar,
49+ pv varchar,
50+ xctime varchar,
51+ name varchar
52+ )WITH(
53+ type ='kafka10',
54+ bootstrapServers ='172.16.8.107:9092',
55+ zookeeperQuorum ='172.16.8.107:2181/kafka',
56+ offsetReset ='latest',
57+ topic ='es_test',
58+ timezone='Asia/Shanghai',
59+ topicIsPattern ='false',
60+ parallelism ='1'
61+ );
62+
4263CREATE TABLE MyResult(
43- channel VARCHAR,
44- pv VARCHAR
64+ pv VARCHAR,
65+ channel VARCHAR
4566 )WITH(
4667 type ='mysql',
47- url ='jdbc:mysql://172.16.8.104 :3306/test?charset=utf8 ',
68+ url ='jdbc:mysql://172.16.10.134 :3306/test',
4869 userName ='dtstack',
4970 password ='abc123',
50- tableName ='pv2 ',
71+ tableName ='myresult ',
5172 parallelism ='1'
52- )
53- ```
73+ );
74+
75+
76+ insert
77+ into
78+ MyResult
79+ select
80+ channel,
81+ pv
82+ from
83+ MyTable
84+ ```
85+
86+ ## 6.结果表数据示例:
87+ ```
88+ mysql> desc myresult;
89+ +---------+--------------+------+-----+---------+-------+
90+ | Field | Type | Null | Key | Default | Extra |
91+ +---------+--------------+------+-----+---------+-------+
92+ | channel | varchar(255) | YES | | NULL | |
93+ | pv | varchar(11) | YES | | NULL | |
94+ +---------+--------------+------+-----+---------+-------+
95+ 2 rows in set (0.00 sec)
96+
97+ mysql> select * from myresult limit 1;
98+ +---------+------+
99+ | channel | pv |
100+ +---------+------+
101+ | aa | mq6 |
102+ ```
0 commit comments