Merge branch '1.8_release_3.10.x' into 1.8_release-github

dapeng · dapeng · commit 0d30a19b68a9 · 2020-05-21T16:23:37.000+08:00
diff --git a/docs/plugin/cassandraSink.md b/docs/plugin/cassandraSink.md
@@ -25,7 +25,7 @@ CREATE TABLE tableName(
 |----|---|
 | tableName| 在 sql 中使用的名称;即注册到flink-table-env上的名称|
 | colName | 列名称|
-| colType | 列类型 [colType支持的类型](docs/colType.md)|
+| colType | 列类型 [colType支持的类型](../colType.md)|
 
 ## 4.参数
 
diff --git a/docs/plugin/clickhouseSide.md b/docs/plugin/clickhouseSide.md
@@ -29,7 +29,7 @@
 
 ## 3.表结构定义
 
- [维表参数信息](docs/plugin/sideParams.md)
+ [维表参数信息](sideParams.md)
 
 clinkhose独有的参数信息
 
diff --git a/docs/plugin/consoleSink.md b/docs/plugin/consoleSink.md
@@ -20,7 +20,7 @@ CREATE TABLE tableName(
 |----|---|
 | tableName| 在 sql 中使用的名称;即注册到flink-table-env上的名称|
 | colName | 列名称|
-| colType | 列类型 [colType支持的类型](docs/colType.md)|
+| colType | 列类型 [colType支持的类型](../colType.md)|
 
 ## 4.参数：
 
diff --git a/docs/plugin/db2Side.md b/docs/plugin/db2Side.md
@@ -28,7 +28,7 @@
 ## 3.表结构定义
   
   
- [维表参数信息](docs/plugin/sideParams.md)
+ [维表参数信息](sideParams.md)
  db2独有的参数配置：
   
  |参数名称|含义|
diff --git a/docs/plugin/db2Sink.md b/docs/plugin/db2Sink.md
@@ -25,7 +25,7 @@ CREATE TABLE tableName(
 |----|---|
 | tableName| db2表名称|
 | colName | 列名称|
-| colType | 列类型 [colType支持的类型](docs/colType.md)|
+| colType | 列类型 [colType支持的类型](../colType.md)|
 | primary key | updateMode为UPSERT时，需要指定的主键信息，不需要和数据库一致|
 
 
diff --git a/docs/plugin/elasticsearch6Side.md b/docs/plugin/elasticsearch6Side.md
@@ -32,7 +32,7 @@
  |----|---|
  | tableName | elasticsearch表名称|
  | colName | 列名称|
- | colType | 列类型 [colType支持的类型](docs/colType.md)|
+ | colType | 列类型 [colType支持的类型](../colType.md)|
  | PERIOD FOR SYSTEM_TIME | 关键字表明该定义的表为维表信息|
  | PRIMARY KEY(keyInfo) | 维表主键定义;多个列之间用逗号隔开|
  
diff --git a/docs/plugin/elasticsearch6Sink.md b/docs/plugin/elasticsearch6Sink.md
@@ -25,7 +25,7 @@ CREATE TABLE tableName(
 |----|---|
 |tableName|在 sql 中使用的名称;即注册到flink-table-env上的名称|  
 |colName|列名称|
-|colType|列类型 [colType支持的类型](docs/colType.md)|
+|colType|列类型 [colType支持的类型](../colType.md)|
    
 ## 4.参数：
 |参数名称|含义|是否必填|默认值|
diff --git a/docs/plugin/elasticsearchSink.md b/docs/plugin/elasticsearchSink.md
@@ -22,7 +22,7 @@ CREATE TABLE tableName(
 |----|---|
 |tableName|在 sql 中使用的名称;即注册到flink-table-env上的名称|  
 |colName|列名称|
-|colType|列类型 [colType支持的类型](docs/colType.md)|
+|colType|列类型 [colType支持的类型](../colType.md)|
    
 ## 4.参数：
 |参数名称|含义|是否必填|默认值|
diff --git a/docs/plugin/hbaseSide.md b/docs/plugin/hbaseSide.md
@@ -33,7 +33,7 @@
   
 ## 4.参数
 
-参数详细说明请看[参数详细说明](./sideParams.md)
+参数详细说明请看[参数详细说明](sideParams.md)
 
 |参数名称|含义|是否必填|默认值|
 |----|---|---|----|
@@ -98,12 +98,12 @@ CREATE TABLE sideTable (
 ```
 hbase(main):002:0> scan 'testFlinkStreamSql'
 ROW     COLUMN+CELL                                                                                                                
- 0      column=wtz:info, timestamp=1587089266719, value=hadoop                                                                     
- 0      column=wtz:message, timestamp=1587089245780, value=hbase                                                                   
- 1      column=wtz:info, timestamp=1587088818432, value=flink                                                                      
- 1      column=wtz:message, timestamp=1587088796633, value=dtstack                                                                 
- 2      column=wtz:info, timestamp=1587088858564, value=sql                                                                        
- 2      column=wtz:message, timestamp=1587088840507, value=stream
+ cfcd208495d565ef66e7dff9f98764dazhangsantest      column=wtz:info, timestamp=1587089266719, value=hadoop                                                                     
+ cfcd208495d565ef66e7dff9f98764dazhangsantest      column=wtz:message, timestamp=1587089245780, value=hbase                                                                   
+ c4ca4238a0b923820dcc509a6f75849blisitest      column=wtz:info, timestamp=1587088818432, value=flink                                                                      
+ c4ca4238a0b923820dcc509a6f75849blisitest      column=wtz:message, timestamp=1587088796633, value=dtstack                                                                 
+ c81e728d9d4c2f636f067f89cc14862cwangwutest      column=wtz:info, timestamp=1587088858564, value=sql                                                                        
+ c81e728d9d4c2f636f067f89cc14862cwangwutest      column=wtz:message, timestamp=1587088840507, value=stream
 ```
 在hbase中，rowKey是一个二进制码流，可以为任意字符串，flinkStreamSql读取rowKey并通过rowKey唯一确定数据，对rowKey没有任何限制,对rowKey可选择的构造包括 md5(alias + alias), '常量',也可以它们的自由组合。
 在本次案例中，rowKey为了简单，设置成了"0,1,2"这样的数值型字符，若有必要，也可以设计得更为复杂。
@@ -138,7 +138,7 @@ CREATE TABLE MyResult(
  CREATE TABLE sideTable (  
         wtz:message varchar as message,
         wtz:info varchar as info , 
-        PRIMARY KEY (rowkey),
+        PRIMARY KEY (md5(rowkey1) + rowkey2 + 'test'),
          PERIOD FOR SYSTEM_TIME
 ) WITH (
         type = 'hbase',
@@ -166,6 +166,6 @@ into
         MyTable a
     left join
         sideTable b
-            on a.id=b.rowkey;
+            on a.id=b.rowkey1 and a.name = b.rowkey2;
 ```
 
diff --git a/docs/plugin/hbaseSink.md b/docs/plugin/hbaseSink.md
@@ -24,7 +24,7 @@ hbase2.0
 |----|---|
 | tableName | 在 sql 中使用的名称;即注册到flink-table-env上的名称
 | colFamily:colName | hbase中的列族名称和列名称
-| colType | 列类型 [colType支持的类型](docs/colType.md)
+| colType | 列类型 [colType支持的类型](../colType.md)
 
 ## 4.参数：
   
diff --git a/docs/plugin/impalaSide.md b/docs/plugin/impalaSide.md
@@ -26,7 +26,7 @@
 
 ## 3.表结构定义
 
- [维表参数信息](docs/plugin/sideParams.md)
+ [维表参数信息](sideParams.md)
 
 impala独有的参数配置
 
diff --git a/docs/plugin/impalaSink.md b/docs/plugin/impalaSink.md
@@ -24,7 +24,7 @@ CREATE TABLE tableName(
 |----|---|
 | tableName| 在 sql 中使用的名称;即注册到flink-table-env上的名称|
 | colName | 列名称|
-| colType | 列类型 [colType支持的类型](docs/plugin/impalaColType.md)|
+| colType | 列类型 [colType支持的类型](impalaColType.md)|
 
 ## 4.参数：
 
diff --git a/docs/plugin/kafkaSink.md b/docs/plugin/kafkaSink.md
@@ -27,7 +27,7 @@ CREATE TABLE tableName(
 |----|---|
 | tableName| 结果表名称|
 | colName | 列名称|
-| colType | 列类型 [colType支持的类型](docs/colType.md)|
+| colType | 列类型 [colType支持的类型](../colType.md)|
 
 ## 4.参数：
 
diff --git a/docs/plugin/kafkaSource.md b/docs/plugin/kafkaSource.md
@@ -29,7 +29,7 @@ CREATE TABLE tableName(
 |----|---|
 | tableName | 在 sql 中使用的名称;即注册到flink-table-env上的名称|
 | colName | 列名称|
-| colType | 列类型 [colType支持的类型](docs/colType.md)|
+| colType | 列类型 [colType支持的类型](../colType.md)|
 | function(colNameX) as aliasName | 支持在定义列信息的时候根据已有列类型生成新的列(函数可以使用系统函数和已经注册的UDF)|
 | WATERMARK FOR colName AS withOffset( colName , delayTime ) | 标识输入流生的watermake生成规则,根据指定的colName(当前支持列的类型为Long &#124; Timestamp) 和delayTime生成waterMark 同时会在注册表的使用附带上rowtime字段(如果未指定则默认添加proctime字段);注意：添加该标识的使用必须设置系统参数 time.characteristic:EventTime; delayTime: 数据最大延迟时间(ms)|
 
@@ -48,7 +48,7 @@ CREATE TABLE tableName(
 |sourcedatatype | 数据类型,avro,csv,json,dt_nest。dt_nest为默认JSON解析器，能够解析嵌套JSON数据类型，其他仅支持非嵌套格式|否|dt_nest|
 |schemaInfo | avro类型使用的schema信息|否||
 |fieldDelimiter |csv类型使用的数据分隔符|否| | |
-|timezone|时区设置[timezone支持的参数](timeZone.md)|否|'Asia/Shanghai'
+|timezone|时区设置[timezone支持的参数](../timeZone.md)|否|'Asia/Shanghai'
 **kafka相关参数可以自定义，使用kafka.开头即可。**
 ```
 kafka.consumer.id
diff --git a/docs/plugin/kuduSide.md b/docs/plugin/kuduSide.md
@@ -36,13 +36,13 @@
  |----|---|
  | tableName | 注册到flink的表名称(可选填;不填默认和hbase对应的表名称相同)|
  | colName | 列名称|
- | colType | 列类型 [colType支持的类型](colType.md)|
+ | colType | 列类型 [colType支持的类型](../colType.md)|
  | PERIOD FOR SYSTEM_TIME | 关键字表明该定义的表为维表信息|
  | PRIMARY KEY(keyInfo) | 维表主键定义;多个列之间用逗号隔开|
   
 ## 4.参数
 
-参数详细说明请看[参数详细说明](./sideParams.md)
+参数详细说明请看[参数详细说明](sideParams.md)
 
 |参数名称|含义|是否必填|默认值|
 |----|---|---|-----|
diff --git a/docs/plugin/kuduSink.md b/docs/plugin/kuduSink.md
@@ -27,7 +27,7 @@ kudu 1.9.0+cdh6.2.0
 |----|---|
 | tableName | 在 sql 中使用的名称;即注册到flink-table-env上的名称
 | colName | 列名称，redis中存储为 表名:主键名:主键值:列名]|
-| colType | 列类型 [colType支持的类型](docs/colType.md)|
+| colType | 列类型 [colType支持的类型](../colType.md)|
 
 
 ## 4.参数：
diff --git a/docs/plugin/mongoSide.md b/docs/plugin/mongoSide.md
@@ -26,7 +26,7 @@
  
 ## 3.表结构定义
   
- [通用维表参数信息](docs/plugin/sideParams.md)
+ [通用维表参数信息](sideParams.md)
  
  
  mongo相关参数配置：
diff --git a/docs/plugin/mongoSink.md b/docs/plugin/mongoSink.md
@@ -25,7 +25,7 @@ CREATE TABLE tableName(
 |----|---|
 | tableName| 在 sql 中使用的名称;即注册到flink-table-env上的名称|
 | colName | 列名称|
-| colType | 列类型 [colType支持的类型](docs/colType.md)|
+| colType | 列类型 [colType支持的类型](../colType.md)|
 
 ## 4.参数：
 
diff --git a/docs/plugin/mysqlSide.md b/docs/plugin/mysqlSide.md
@@ -29,7 +29,7 @@
  
 ## 3.表结构定义
 
- [维表参数信息](docs/plugin/sideParams.md)
+ [维表参数信息](sideParams.md)
  
   mysql独有的参数配置：
 
diff --git a/docs/plugin/mysqlSink.md b/docs/plugin/mysqlSink.md
@@ -25,7 +25,7 @@ CREATE TABLE tableName(
 |----|---|
 | tableName| 结果表名称|
 | colName | 列名称|
-| colType | 列类型 [colType支持的类型](docs/colType.md)|
+| colType | 列类型 [colType支持的类型](../colType.md)|
 
 ## 4.参数：
 
diff --git a/docs/plugin/oracleSide.md b/docs/plugin/oracleSide.md
@@ -31,7 +31,7 @@
  10g 11g
  
 ## 3. 表结构定义
-   [维表参数](docs/plugin/sideParams.md)
+   [维表参数](sideParams.md)
    
    
   oracle独有的参数配置：
diff --git a/docs/plugin/oracleSink.md b/docs/plugin/oracleSink.md
@@ -24,7 +24,7 @@ CREATE TABLE tableName(
 |----|---|
 | tableName| oracle表名称|
 | colName | 列名称|
-| colType | 列类型 [colType支持的类型](docs/colType.md)|
+| colType | 列类型 [colType支持的类型](../colType.md)|
 
 ## 4.参数：
 
diff --git a/docs/plugin/polardbSide.md b/docs/plugin/polardbSide.md
@@ -28,7 +28,7 @@
  |----|---|
  | tableName | polardb表名称|
  | colName | 列名称|
- | colType | 列类型 [colType支持的类型](docs/colType.md)|
+ | colType | 列类型 [colType支持的类型](../colType.md)|
  | PERIOD FOR SYSTEM_TIME | 关键字表明该定义的表为维表信息|
  | PRIMARY KEY(keyInfo) | 维表主键定义;多个列之间用逗号隔开|
  
diff --git a/docs/plugin/polardbSink.md b/docs/plugin/polardbSink.md
@@ -24,7 +24,7 @@ CREATE TABLE tableName(
 |----|---|
 | tableName| polardb表名称|
 | colName | 列名称|
-| colType | 列类型 [colType支持的类型](docs/colType.md)|
+| colType | 列类型 [colType支持的类型](../colType.md)|
 
 ## 4.参数：
 
diff --git a/docs/plugin/postgresqlSide.md b/docs/plugin/postgresqlSide.md
@@ -29,7 +29,7 @@
 
 ## 3.表结构定义
 
- [维表参数信息](docs/plugin/sideParams.md)
+ [维表参数信息](sideParams.md)
 
 postgresql独有的参数配置
 
diff --git a/docs/plugin/postgresqlSink.md b/docs/plugin/postgresqlSink.md
@@ -25,7 +25,7 @@ CREATE TABLE tableName(
 |----|---|
 | tableName| 在 sql 中使用的名称;即注册到flink-table-env上的名称|
 | colName | 列名称|
-| colType | 列类型 [colType支持的类型](docs/colType.md)|
+| colType | 列类型 [colType支持的类型](../colType.md)|
 | primary key | updateMode为UPSERT时，需要指定的主键信息|
 
 
diff --git a/docs/plugin/redisSide.md b/docs/plugin/redisSide.md
@@ -36,7 +36,7 @@
   
 ## 4.参数
 
-参数详细说明请看[参数详细说明](./sideParams.md)
+参数详细说明请看[参数详细说明](sideParams.md)
 
 |参数名称|含义|是否必填|默认值|
 |----|---|---|----|
diff --git a/docs/plugin/sqlserverSide.md b/docs/plugin/sqlserverSide.md
@@ -29,7 +29,7 @@
 
 ## 3.表结构定义
 
- [维表参数信息](docs/plugin/sideParams.md)
+ [维表参数信息](sideParams.md)
 
 sqlserver独有的参数配置
 
diff --git a/docs/plugin/sqlserverSink.md b/docs/plugin/sqlserverSink.md
@@ -25,7 +25,7 @@ CREATE TABLE tableName(
 |----|---|
 | tableName| sqlserver表名称|
 | colName | 列名称|
-| colType | 列类型 [colType支持的类型](docs/colType.md)|
+| colType | 列类型 [colType支持的类型](../colType.md)|
 | primary key | updateMode为UPSERT时，需要指定的主键信息|
 
 ## 4.参数：
