File tree 7 files changed +53
-13
lines changed
7 files changed +53
-13
lines changed Original file line number Diff line number Diff line change @@ -35,7 +35,10 @@ CREATE TABLE tableName(
35
35
| userName | clickhouse 连接用户名 | 是||
36
36
| password | clickhouse 连接密码| 是||
37
37
| tableName | clickhouse 表名称| 是||
38
- | parallelism | 并行度设置| 否| 1|
38
+ | parallelism | 并行度设置| 否| 1|| updateMode | 回溯流的处理模式,update或者append,默认根据主键判断,update模式下需要指定主键| 否||
39
+ | updateMode | 仅支持append| 否| append|
40
+ | batchSize | 批插入数量| 否| 100|
41
+ | batchWaitInterval | 自动触发刷新的间隔| 否| 10000,单位毫秒|
39
42
40
43
## 5.样例:
41
44
```
Original file line number Diff line number Diff line change @@ -45,6 +45,8 @@ CREATE TABLE tableName(
45
45
| enablePartition | 是否支持分区 | 否| false|
46
46
| partitionFields | 分区字段名| 否,enablePartition='true'时为必填||
47
47
| parallelism | 并行度设置| 否| 1|
48
+ | batchSize | 批插入数量| 否| 100|
49
+ | batchWaitInterval | 自动触发刷新的间隔| 否| 10000,单位毫秒|
48
50
49
51
50
52
## 5.样例:
Original file line number Diff line number Diff line change @@ -35,19 +35,38 @@ CREATE TABLE tableName(
35
35
| userName | mysql连接用户名 | 是||
36
36
| password | mysql连接密码| 是||
37
37
| tableName | mysql表名称| 是||
38
- | parallelism | 并行度设置| 否| 1|
38
+ | parallelism | 并行度设置| 否||
39
+ | updateMode | 回溯流的处理模式,update或者append,默认根据主键判断,update模式下需要指定主键| 否||
40
+ | allReplace | 主键冲突时对数据的处理,全部替换or 非空值替换。| 否| false|
41
+ | batchSize | 批插入数量| 否| 100|
42
+ | batchWaitInterval | 自动触发刷新的间隔| 否| 10000,单位毫秒|
43
+
44
+
45
+
46
+
47
+
48
+
49
+
50
+
39
51
40
52
## 5.样例:
41
53
```
42
- CREATE TABLE MyResult(
43
- channel VARCHAR,
44
- pv VARCHAR
45
- )WITH(
46
- type ='mysql',
47
- url ='jdbc:mysql://172.16.8.104:3306/test?charset=utf8',
48
- userName ='dtstack',
49
- password ='abc123',
50
- tableName ='pv2',
51
- parallelism ='1'
52
- )
54
+ CREATE TABLE MyResult (
55
+ id varchar,
56
+ name varchar,
57
+ city varchar,
58
+ b3 varchar,
59
+ primary key (id)
60
+ ) WITH (
61
+ type='mysql',
62
+ url='jdbc:mysql://172.16.8.109:3306/mqtest?charset=utf8',
63
+ userName='dtstack',
64
+ password='abc123',
65
+ tableName='sink_table_02',
66
+ batchSize='1',
67
+ updateMode = 'update',
68
+ updateMode = 'append',
69
+ --allReplace = 'false'
70
+ allReplace = 'true'
71
+ );
53
72
```
Original file line number Diff line number Diff line change @@ -37,6 +37,10 @@ CREATE TABLE tableName(
37
37
| tableName | oracle表名称| 是||
38
38
| schema | oracle 的schema| 否| 当前登录用户|
39
39
| parallelism | 并行度设置| 否| 1|
40
+ | updateMode | 回溯流的处理模式,update或者append,默认根据主键判断,update模式下需要指定主键| 否||
41
+ | allReplace | 主键冲突时对数据的处理,全部替换or 非空值替换。| 否| false|
42
+ | batchSize | 批插入数量| 否| 100|
43
+ | batchWaitInterval | 自动触发刷新的间隔| 否| 10000,单位毫秒|
40
44
41
45
## 5.样例:
42
46
```
Original file line number Diff line number Diff line change @@ -36,6 +36,10 @@ CREATE TABLE tableName(
36
36
| password | polardb连接密码| 是||
37
37
| tableName | polardb表名称| 是||
38
38
| parallelism | 并行度设置| 否| 1|
39
+ | updateMode | 回溯流的处理模式,update或者append,默认根据主键判断,update模式下需要指定主键| 否||
40
+ | allReplace | 主键冲突时对数据的处理,全部替换or 非空值替换。| 否| false|
41
+ | batchSize | 批插入数量| 否| 100|
42
+ | batchWaitInterval | 自动触发刷新的间隔| 否| 10000,单位毫秒|
39
43
40
44
## 5.样例:
41
45
```
Original file line number Diff line number Diff line change @@ -36,6 +36,10 @@ CREATE TABLE tableName(
36
36
| password | postgresql连接密码| 是||
37
37
| tableName | postgresqll表名称| 是||
38
38
| parallelism | 并行度设置| 否| 1|
39
+ | updateMode | 回溯流的处理模式,update或者append,默认根据主键判断,update模式下需要指定主键| 否||
40
+ | allReplace | 主键冲突时对数据的处理,全部替换or 非空值替换。| 否| false|
41
+ | batchSize | 批插入数量| 否| 100|
42
+ | batchWaitInterval | 自动触发刷新的间隔| 否| 10000,单位毫秒|
39
43
40
44
## 5.样例:
41
45
```
Original file line number Diff line number Diff line change @@ -36,6 +36,10 @@ CREATE TABLE tableName(
36
36
| password | sqlserver连接密码| 是||
37
37
| tableName | sqlserver表名称| 是||
38
38
| parallelism | 并行度设置| 否| 1|
39
+ | updateMode | 回溯流的处理模式,update或者append,默认根据主键判断,update模式下需要指定主键| 否||
40
+ | allReplace | 主键冲突时对数据的处理,全部替换or 非空值替换。| 否| false|
41
+ | batchSize | 批插入数量| 否| 100|
42
+ | batchWaitInterval | 自动触发刷新的间隔| 否| 10000,单位毫秒|
39
43
40
44
## 5.样例:
41
45
```
You can’t perform that action at this time.
0 commit comments