Skip to content

Commit 0d30a19

Browse files
author
dapeng
committed
Merge branch '1.8_release_3.10.x' into 1.8_release-github
2 parents c619943 + e69f484 commit 0d30a19

29 files changed

+39
-39
lines changed

‎docs/plugin/cassandraSink.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ CREATE TABLE tableName(
2525
|----|---|
2626
| tableName| 在 sql 中使用的名称;即注册到flink-table-env上的名称|
2727
| colName | 列名称|
28-
| colType | 列类型 [colType支持的类型](docs/colType.md)|
28+
| colType | 列类型 [colType支持的类型](../colType.md)|
2929

3030
## 4.参数
3131

‎docs/plugin/clickhouseSide.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929

3030
## 3.表结构定义
3131

32-
[维表参数信息](docs/plugin/sideParams.md)
32+
[维表参数信息](sideParams.md)
3333

3434
clinkhose独有的参数信息
3535

‎docs/plugin/consoleSink.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ CREATE TABLE tableName(
2020
|----|---|
2121
| tableName| 在 sql 中使用的名称;即注册到flink-table-env上的名称|
2222
| colName | 列名称|
23-
| colType | 列类型 [colType支持的类型](docs/colType.md)|
23+
| colType | 列类型 [colType支持的类型](../colType.md)|
2424

2525
## 4.参数：
2626

‎docs/plugin/db2Side.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@
2828
## 3.表结构定义
2929

3030

31-
[维表参数信息](docs/plugin/sideParams.md)
31+
[维表参数信息](sideParams.md)
3232
db2独有的参数配置：
3333

3434
|参数名称|含义|

‎docs/plugin/db2Sink.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ CREATE TABLE tableName(
2525
|----|---|
2626
| tableName| db2表名称|
2727
| colName | 列名称|
28-
| colType | 列类型 [colType支持的类型](docs/colType.md)|
28+
| colType | 列类型 [colType支持的类型](../colType.md)|
2929
| primary key | updateMode为UPSERT时，需要指定的主键信息，不需要和数据库一致|
3030

3131

‎docs/plugin/elasticsearch6Side.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232
|----|---|
3333
| tableName | elasticsearch表名称|
3434
| colName | 列名称|
35-
| colType | 列类型 [colType支持的类型](docs/colType.md)|
35+
| colType | 列类型 [colType支持的类型](../colType.md)|
3636
| PERIOD FOR SYSTEM_TIME | 关键字表明该定义的表为维表信息|
3737
| PRIMARY KEY(keyInfo) | 维表主键定义;多个列之间用逗号隔开|
3838

‎docs/plugin/elasticsearch6Sink.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ CREATE TABLE tableName(
2525
|----|---|
2626
|tableName|在 sql 中使用的名称;即注册到flink-table-env上的名称|
2727
|colName|列名称|
28-
|colType|列类型 [colType支持的类型](docs/colType.md)|
28+
|colType|列类型 [colType支持的类型](../colType.md)|
2929

3030
## 4.参数：
3131
|参数名称|含义|是否必填|默认值|

‎docs/plugin/elasticsearchSink.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ CREATE TABLE tableName(
2222
|----|---|
2323
|tableName|在 sql 中使用的名称;即注册到flink-table-env上的名称|
2424
|colName|列名称|
25-
|colType|列类型 [colType支持的类型](docs/colType.md)|
25+
|colType|列类型 [colType支持的类型](../colType.md)|
2626

2727
## 4.参数：
2828
|参数名称|含义|是否必填|默认值|

‎docs/plugin/hbaseSide.md

+9-9
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333

3434
## 4.参数
3535

36-
参数详细说明请看[参数详细说明](./sideParams.md)
36+
参数详细说明请看[参数详细说明](sideParams.md)
3737

3838
|参数名称|含义|是否必填|默认值|
3939
|----|---|---|----|
@@ -98,12 +98,12 @@ CREATE TABLE sideTable (
9898
```
9999
hbase(main):002:0> scan 'testFlinkStreamSql'
100100
ROW COLUMN+CELL
101-
0 column=wtz:info, timestamp=1587089266719, value=hadoop
102-
0 column=wtz:message, timestamp=1587089245780, value=hbase
103-
1 column=wtz:info, timestamp=1587088818432, value=flink
104-
1 column=wtz:message, timestamp=1587088796633, value=dtstack
105-
2 column=wtz:info, timestamp=1587088858564, value=sql
106-
2 column=wtz:message, timestamp=1587088840507, value=stream
101+
cfcd208495d565ef66e7dff9f98764dazhangsantest column=wtz:info, timestamp=1587089266719, value=hadoop
102+
cfcd208495d565ef66e7dff9f98764dazhangsantest column=wtz:message, timestamp=1587089245780, value=hbase
103+
c4ca4238a0b923820dcc509a6f75849blisitest column=wtz:info, timestamp=1587088818432, value=flink
104+
c4ca4238a0b923820dcc509a6f75849blisitest column=wtz:message, timestamp=1587088796633, value=dtstack
105+
c81e728d9d4c2f636f067f89cc14862cwangwutest column=wtz:info, timestamp=1587088858564, value=sql
106+
c81e728d9d4c2f636f067f89cc14862cwangwutest column=wtz:message, timestamp=1587088840507, value=stream
107107
```
108108
在hbase中，rowKey是一个二进制码流，可以为任意字符串，flinkStreamSql读取rowKey并通过rowKey唯一确定数据，对rowKey没有任何限制,对rowKey可选择的构造包括 md5(alias + alias), '常量',也可以它们的自由组合。
109109
在本次案例中，rowKey为了简单，设置成了"0,1,2"这样的数值型字符，若有必要，也可以设计得更为复杂。
@@ -138,7 +138,7 @@ CREATE TABLE MyResult(
138138
CREATE TABLE sideTable (
139139
wtz:message varchar as message,
140140
wtz:info varchar as info ,
141-
PRIMARY KEY (rowkey),
141+
PRIMARY KEY (md5(rowkey1) + rowkey2 + 'test'),
142142
PERIOD FOR SYSTEM_TIME
143143
) WITH (
144144
type = 'hbase',
@@ -166,6 +166,6 @@ into
166166
MyTable a
167167
left join
168168
sideTable b
169-
on a.id=b.rowkey;
169+
on a.id=b.rowkey1 and a.name = b.rowkey2;
170170
```
171171

‎docs/plugin/hbaseSink.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ hbase2.0
2424
|----|---|
2525
| tableName | 在 sql 中使用的名称;即注册到flink-table-env上的名称
2626
| colFamily:colName | hbase中的列族名称和列名称
27-
| colType | 列类型 [colType支持的类型](docs/colType.md)
27+
| colType | 列类型 [colType支持的类型](../colType.md)
2828

2929
## 4.参数：
3030

‎docs/plugin/impalaSide.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626

2727
## 3.表结构定义
2828

29-
[维表参数信息](docs/plugin/sideParams.md)
29+
[维表参数信息](sideParams.md)
3030

3131
impala独有的参数配置
3232

‎docs/plugin/impalaSink.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ CREATE TABLE tableName(
2424
|----|---|
2525
| tableName| 在 sql 中使用的名称;即注册到flink-table-env上的名称|
2626
| colName | 列名称|
27-
| colType | 列类型 [colType支持的类型](docs/plugin/impalaColType.md)|
27+
| colType | 列类型 [colType支持的类型](impalaColType.md)|
2828

2929
## 4.参数：
3030

‎docs/plugin/kafkaSink.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ CREATE TABLE tableName(
2727
|----|---|
2828
| tableName| 结果表名称|
2929
| colName | 列名称|
30-
| colType | 列类型 [colType支持的类型](docs/colType.md)|
30+
| colType | 列类型 [colType支持的类型](../colType.md)|
3131

3232
## 4.参数：
3333

‎docs/plugin/kafkaSource.md

+2-2
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ CREATE TABLE tableName(
2929
|----|---|
3030
| tableName | 在 sql 中使用的名称;即注册到flink-table-env上的名称|
3131
| colName | 列名称|
32-
| colType | 列类型 [colType支持的类型](docs/colType.md)|
32+
| colType | 列类型 [colType支持的类型](../colType.md)|
3333
| function(colNameX) as aliasName | 支持在定义列信息的时候根据已有列类型生成新的列(函数可以使用系统函数和已经注册的UDF)|
3434
| WATERMARK FOR colName AS withOffset( colName , delayTime ) | 标识输入流生的watermake生成规则,根据指定的colName(当前支持列的类型为Long | Timestamp) 和delayTime生成waterMark 同时会在注册表的使用附带上rowtime字段(如果未指定则默认添加proctime字段);注意：添加该标识的使用必须设置系统参数 time.characteristic:EventTime; delayTime: 数据最大延迟时间(ms)|
3535

@@ -48,7 +48,7 @@ CREATE TABLE tableName(
4848
|sourcedatatype | 数据类型,avro,csv,json,dt_nest。dt_nest为默认JSON解析器，能够解析嵌套JSON数据类型，其他仅支持非嵌套格式|否|dt_nest|
4949
|schemaInfo | avro类型使用的schema信息|否||
5050
|fieldDelimiter |csv类型使用的数据分隔符|否| | |
51-
|timezone|时区设置[timezone支持的参数](timeZone.md)|否|'Asia/Shanghai'
51+
|timezone|时区设置[timezone支持的参数](../timeZone.md)|否|'Asia/Shanghai'
5252
**kafka相关参数可以自定义，使用kafka.开头即可。**
5353
```
5454
kafka.consumer.id

‎docs/plugin/kuduSide.md

+2-2
Original file line numberDiff line numberDiff line change
@@ -36,13 +36,13 @@
3636
|----|---|
3737
| tableName | 注册到flink的表名称(可选填;不填默认和hbase对应的表名称相同)|
3838
| colName | 列名称|
39-
| colType | 列类型 [colType支持的类型](colType.md)|
39+
| colType | 列类型 [colType支持的类型](../colType.md)|
4040
| PERIOD FOR SYSTEM_TIME | 关键字表明该定义的表为维表信息|
4141
| PRIMARY KEY(keyInfo) | 维表主键定义;多个列之间用逗号隔开|
4242

4343
## 4.参数
4444

45-
参数详细说明请看[参数详细说明](./sideParams.md)
45+
参数详细说明请看[参数详细说明](sideParams.md)
4646

4747
|参数名称|含义|是否必填|默认值|
4848
|----|---|---|-----|

‎docs/plugin/kuduSink.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ kudu 1.9.0+cdh6.2.0
2727
|----|---|
2828
| tableName | 在 sql 中使用的名称;即注册到flink-table-env上的名称
2929
| colName | 列名称，redis中存储为 表名:主键名:主键值:列名]|
30-
| colType | 列类型 [colType支持的类型](docs/colType.md)|
30+
| colType | 列类型 [colType支持的类型](../colType.md)|
3131

3232

3333
## 4.参数：

‎docs/plugin/mongoSide.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626

2727
## 3.表结构定义
2828

29-
[通用维表参数信息](docs/plugin/sideParams.md)
29+
[通用维表参数信息](sideParams.md)
3030

3131

3232
mongo相关参数配置：

‎docs/plugin/mongoSink.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ CREATE TABLE tableName(
2525
|----|---|
2626
| tableName| 在 sql 中使用的名称;即注册到flink-table-env上的名称|
2727
| colName | 列名称|
28-
| colType | 列类型 [colType支持的类型](docs/colType.md)|
28+
| colType | 列类型 [colType支持的类型](../colType.md)|
2929

3030
## 4.参数：
3131

‎docs/plugin/mysqlSide.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929

3030
## 3.表结构定义
3131

32-
[维表参数信息](docs/plugin/sideParams.md)
32+
[维表参数信息](sideParams.md)
3333

3434
mysql独有的参数配置：
3535

‎docs/plugin/mysqlSink.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ CREATE TABLE tableName(
2525
|----|---|
2626
| tableName| 结果表名称|
2727
| colName | 列名称|
28-
| colType | 列类型 [colType支持的类型](docs/colType.md)|
28+
| colType | 列类型 [colType支持的类型](../colType.md)|
2929

3030
## 4.参数：
3131

‎docs/plugin/oracleSide.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
10g 11g
3232

3333
## 3. 表结构定义
34-
[维表参数](docs/plugin/sideParams.md)
34+
[维表参数](sideParams.md)
3535

3636

3737
oracle独有的参数配置：

‎docs/plugin/oracleSink.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ CREATE TABLE tableName(
2424
|----|---|
2525
| tableName| oracle表名称|
2626
| colName | 列名称|
27-
| colType | 列类型 [colType支持的类型](docs/colType.md)|
27+
| colType | 列类型 [colType支持的类型](../colType.md)|
2828

2929
## 4.参数：
3030

‎docs/plugin/polardbSide.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@
2828
|----|---|
2929
| tableName | polardb表名称|
3030
| colName | 列名称|
31-
| colType | 列类型 [colType支持的类型](docs/colType.md)|
31+
| colType | 列类型 [colType支持的类型](../colType.md)|
3232
| PERIOD FOR SYSTEM_TIME | 关键字表明该定义的表为维表信息|
3333
| PRIMARY KEY(keyInfo) | 维表主键定义;多个列之间用逗号隔开|
3434

‎docs/plugin/polardbSink.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ CREATE TABLE tableName(
2424
|----|---|
2525
| tableName| polardb表名称|
2626
| colName | 列名称|
27-
| colType | 列类型 [colType支持的类型](docs/colType.md)|
27+
| colType | 列类型 [colType支持的类型](../colType.md)|
2828

2929
## 4.参数：
3030

‎docs/plugin/postgresqlSide.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929

3030
## 3.表结构定义
3131

32-
[维表参数信息](docs/plugin/sideParams.md)
32+
[维表参数信息](sideParams.md)
3333

3434
postgresql独有的参数配置
3535

‎docs/plugin/postgresqlSink.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ CREATE TABLE tableName(
2525
|----|---|
2626
| tableName| 在 sql 中使用的名称;即注册到flink-table-env上的名称|
2727
| colName | 列名称|
28-
| colType | 列类型 [colType支持的类型](docs/colType.md)|
28+
| colType | 列类型 [colType支持的类型](../colType.md)|
2929
| primary key | updateMode为UPSERT时，需要指定的主键信息|
3030

3131

‎docs/plugin/redisSide.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@
3636

3737
## 4.参数
3838

39-
参数详细说明请看[参数详细说明](./sideParams.md)
39+
参数详细说明请看[参数详细说明](sideParams.md)
4040

4141
|参数名称|含义|是否必填|默认值|
4242
|----|---|---|----|

‎docs/plugin/sqlserverSide.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929

3030
## 3.表结构定义
3131

32-
[维表参数信息](docs/plugin/sideParams.md)
32+
[维表参数信息](sideParams.md)
3333

3434
sqlserver独有的参数配置
3535

‎docs/plugin/sqlserverSink.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ CREATE TABLE tableName(
2525
|----|---|
2626
| tableName| sqlserver表名称|
2727
| colName | 列名称|
28-
| colType | 列类型 [colType支持的类型](docs/colType.md)|
28+
| colType | 列类型 [colType支持的类型](../colType.md)|
2929
| primary key | updateMode为UPSERT时，需要指定的主键信息|
3030

3131
## 4.参数：

0 commit comments

Comments
 (0)