ck impala sink doc

Author: todd5167

docs/plugin/clickhouseSink.md

@@ -24,7 +24,7 @@ CREATE TABLE tableName(
 |----|---|
 | tableName| clickhouse表名称|
 | colName | 列名称|
-| colType | 列类型 [colType支持的类型](docs/colType.md)|
+| colType | clickhouse基本数据类型，不包括Array，Tuple,Nested等|
 
 ## 4.参数：
 
@@ -36,18 +36,87 @@ CREATE TABLE tableName(
 | password | clickhouse 连接密码|是||
 | tableName | clickhouse 表名称|是||
 | parallelism | 并行度设置|否|1|
+|updateMode| 只支持APPEND模式，过滤掉回撤数据|||
+
 
 ## 5.样例：
+
+
 ```
+
+CREATE TABLE source1 (
+    id int,
+    name VARCHAR
+)WITH(
+    type ='kafka11',
+    bootstrapServers ='172.16.8.107:9092',
+    zookeeperQuorum ='172.16.8.107:2181/kafka',
+    offsetReset ='latest',
+    topic ='mqTest03',
+    timezone='Asia/Shanghai',
+    topicIsPattern ='false'
+ );
+
+
+
+CREATE TABLE source2(
+    id int,
+    address VARCHAR
+)WITH(
+    type ='kafka11',
+    bootstrapServers ='172.16.8.107:9092',
+    zookeeperQuorum ='172.16.8.107:2181/kafka',
+    offsetReset ='latest',
+    topic ='mqTest04',
+    timezone='Asia/Shanghai',
+    topicIsPattern ='false'
+);
+
+
 CREATE TABLE MyResult(
-    channel VARCHAR,
-    pv VARCHAR
- )WITH(
-    type ='clickhouse',
-    url ='jdbc:clickhouse://172.16.8.104:3306/test?charset=utf8',
-    userName ='dtstack',
-    password ='abc123',
-    tableName ='pv2',
-    parallelism ='1'
- )
- ```
+    id int,
+    name VARCHAR,
+    address VARCHAR
+)WITH(
+    type='clickhouse',
+    url='jdbc:clickhouse://172.16.10.168:8123/tudou?charset=utf8',
+    userName='dtstack',
+    password='abc123',
+    tableName='MyResult',
+    updateMode = 'append'
+);
+
+insert into MyResult
+select 
+	s1.id,
+	s1.name,
+	s2.address
+from 
+	source1 s1
+left join
+	source2 s2
+on 	
+	s1.id = s2.id
+
+
+ ```
+ 
+
+**Clickhouse建表语句**
+
+ 
+ ```aidl
+CREATE TABLE tudou.MyResult (`id` Int64, `name` String, `address` String)
+    ENGINE = MergeTree PARTITION BY address ORDER BY id SETTINGS index_granularity = 8192
+```
+ 
+ 
+ 
+ 
+数据结果：
+
+向Topic mqTest03 发送数据  {"name":"maqi","id":1001}  插入 (1001,"maqi",null)
+
+向Topic mqTest04 发送数据  {"address":"hz","id":1001} 插入  (1001,"maqi","hz")
+ 
+ 

docs/plugin/impalaColType.md

@@ -0,0 +1,14 @@
+| 支持的类型 | java对应类型   |
+| ------ | ----- |
+| boolean    | Boolean |
+| char    | Character |
+| double | Double|
+| float  | Float|
+| tinyint    | Byte |
+| smallint | Short|
+| int        | Integer |
+| bigint     | Long |
+| decimal |BigDecimal|
+| string | String |
+| varchar | String |
+| timestamp | Timestamp |

docs/plugin/impalaSink.md

@@ -24,7 +24,7 @@ CREATE TABLE tableName(
 |----|---|
 | tableName| 在 sql 中使用的名称;即注册到flink-table-env上的名称|
 | colName | 列名称|
-| colType | 列类型 [colType支持的类型](docs/colType.md)|
+| colType | 列类型 [colType支持的类型](docs/plugin/impalaColType.md)|
 
 ## 4.参数：
 
@@ -45,6 +45,8 @@ CREATE TABLE tableName(
 | enablePartition | 是否支持分区 |否|false|
 | partitionFields | 分区字段名|否，enablePartition='true'时为必填||
 | parallelism | 并行度设置|否|1|
+| parallelism | 并行度设置|否|1|
+|updateMode| 只支持APPEND模式，过滤掉回撤数据|||
 
 
 ## 5.样例：