File tree Expand file tree Collapse file tree 7 files changed +53
-13
lines changed Expand file tree Collapse file tree 7 files changed +53
-13
lines changed Original file line number Diff line number Diff line change @@ -35,7 +35,10 @@ CREATE TABLE tableName(
3535| userName |  clickhouse 连接用户名 | 是|| 
3636|  password |  clickhouse 连接密码| 是|| 
3737|  tableName |  clickhouse 表名称| 是|| 
38- |  parallelism |  并行度设置| 否| 1| 
38+ |  parallelism |  并行度设置| 否| 1||  updateMode |  回溯流的处理模式,update或者append,默认根据主键判断,update模式下需要指定主键| 否|| 
39+ |  updateMode |  仅支持append| 否| append| 
40+ |  batchSize |  批插入数量| 否| 100| 
41+ |  batchWaitInterval | 自动触发刷新的间隔| 否| 10000,单位毫秒| 
3942
4043## 5.样例:  
4144``` 
Original file line number Diff line number Diff line change @@ -45,6 +45,8 @@ CREATE TABLE tableName(
4545|  enablePartition |  是否支持分区 | 否| false| 
4646|  partitionFields |  分区字段名| 否,enablePartition='true'时为必填|| 
4747|  parallelism |  并行度设置| 否| 1| 
48+ |  batchSize |  批插入数量| 否| 100| 
49+ |  batchWaitInterval | 自动触发刷新的间隔| 否| 10000,单位毫秒| 
4850
4951
5052## 5.样例:  
Original file line number Diff line number Diff line change @@ -35,19 +35,38 @@ CREATE TABLE tableName(
3535| userName |  mysql连接用户名 | 是|| 
3636|  password |  mysql连接密码| 是|| 
3737|  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+ 
3951
4052## 5.样例:  
4153``` 
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+  ); 
5372``` 
Original file line number Diff line number Diff line change @@ -37,6 +37,10 @@ CREATE TABLE tableName(
3737|  tableName |  oracle表名称| 是|| 
3838|  schema |  oracle 的schema| 否| 当前登录用户| 
3939|  parallelism |  并行度设置| 否| 1| 
40+ |  updateMode |  回溯流的处理模式,update或者append,默认根据主键判断,update模式下需要指定主键| 否|| 
41+ |  allReplace |  主键冲突时对数据的处理,全部替换or 非空值替换。| 否| false| 
42+ |  batchSize |  批插入数量| 否| 100| 
43+ |  batchWaitInterval | 自动触发刷新的间隔| 否| 10000,单位毫秒| 
4044
4145## 5.样例:  
4246``` 
Original file line number Diff line number Diff line change @@ -36,6 +36,10 @@ CREATE TABLE tableName(
3636|  password |  polardb连接密码| 是|| 
3737|  tableName |  polardb表名称| 是|| 
3838|  parallelism |  并行度设置| 否| 1| 
39+ |  updateMode |  回溯流的处理模式,update或者append,默认根据主键判断,update模式下需要指定主键| 否|| 
40+ |  allReplace |  主键冲突时对数据的处理,全部替换or 非空值替换。| 否| false| 
41+ |  batchSize |  批插入数量| 否| 100| 
42+ |  batchWaitInterval | 自动触发刷新的间隔| 否| 10000,单位毫秒| 
3943
4044## 5.样例:  
4145``` 
Original file line number Diff line number Diff line change @@ -36,6 +36,10 @@ CREATE TABLE tableName(
3636|  password |  postgresql连接密码| 是|| 
3737|  tableName |  postgresqll表名称| 是|| 
3838|  parallelism |  并行度设置| 否| 1| 
39+ |  updateMode |  回溯流的处理模式,update或者append,默认根据主键判断,update模式下需要指定主键| 否|| 
40+ |  allReplace |  主键冲突时对数据的处理,全部替换or 非空值替换。| 否| false| 
41+ |  batchSize |  批插入数量| 否| 100| 
42+ |  batchWaitInterval | 自动触发刷新的间隔| 否| 10000,单位毫秒| 
3943
4044## 5.样例:  
4145``` 
Original file line number Diff line number Diff line change @@ -36,6 +36,10 @@ CREATE TABLE tableName(
3636|  password |  sqlserver连接密码| 是|| 
3737|  tableName |  sqlserver表名称| 是|| 
3838|  parallelism |  并行度设置| 否| 1| 
39+ |  updateMode |  回溯流的处理模式,update或者append,默认根据主键判断,update模式下需要指定主键| 否|| 
40+ |  allReplace |  主键冲突时对数据的处理,全部替换or 非空值替换。| 否| false| 
41+ |  batchSize |  批插入数量| 否| 100| 
42+ |  batchWaitInterval | 自动触发刷新的间隔| 否| 10000,单位毫秒| 
3943
4044## 5.样例:  
4145``` 
 
 
   
 
     
   
   
          
    
    
     
    
      
     
     
    You can’t perform that action at this time.
  
 
    
  
    
      
        
     
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments