Skip to content

Commit 4d65e3d

Browse files
zoudaokoulifezoudaokoulife
committed
编辑readme.md
1 parent d7df27f commit 4d65e3d

File tree

6 files changed

+44
-46
lines changed

6 files changed

+44
-46
lines changed

‎docs/elasticsearchSink.md‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -25,15 +25,15 @@ CREATE TABLE tableName(
2525
|colType|列类型 [colType支持的类型](colType.md)|
2626

2727
## 4.参数：
28-
|参数名称|含义|是否必填|
29-
|----|---|---|
30-
|type|表明 输出表类型[mysql|hbase|elasticsearch]|是|
31-
|address | 连接ES Transport地址(tcp地址)|是|
32-
|cluster | ES 集群名称 |是|
33-
|index | 选择的ES上的index名称|是|
34-
|estype | 选择ES上的type名称|是|
35-
|id | 生成id的规则(当前是根据指定的字段pos获取字段信息,拼接生成id)|是|
36-
|parallelism | 并行度设置|否|
28+
|参数名称|含义|是否必填|默认值|
29+
|----|---|---|----|
30+
|type|表明 输出表类型[mysql\|hbase\|elasticsearch]|是||
31+
|address | 连接ES Transport地址(tcp地址)|是||
32+
|cluster | ES 集群名称 |是||
33+
|index | 选择的ES上的index名称|是||
34+
|estype | 选择ES上的type名称|是||
35+
|id | 生成id的规则(当前是根据指定的字段pos获取字段信息,拼接生成id)|是||
36+
|parallelism | 并行度设置|否|1|
3737

3838
## 5.样例：
3939
```

‎docs/hbaseSide.md‎

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -33,21 +33,21 @@
3333

3434
## 3.参数
3535

36-
|参数名称|含义|是否必填|
37-
|----|---|---|
38-
| type | 表明维表的类型[hbase|mysql]|是|
39-
| zookeeperQuorum | hbase 的zk地址;格式ip:port[;ip:port]|是|
40-
| zookeeperParent | hbase 的zk parent路径|是|
41-
| tableName | hbase 的表名称|是|
42-
| cache | 维表缓存策略(NONE/LRU)|否|
43-
| partitionedJoin | 是否在維表join之前先根据 設定的key 做一次keyby操作(可以減少维表的数据缓存量)|否|
36+
|参数名称|含义|是否必填|默认值|
37+
|----|---|---|----|
38+
| type | 表明维表的类型[hbase\|mysql]|是||
39+
| zookeeperQuorum | hbase 的zk地址;格式ip:port[;ip:port]|是||
40+
| zookeeperParent | hbase 的zk parent路径|是||
41+
| tableName | hbase 的表名称|是||
42+
| cache | 维表缓存策略(NONE/LRU)|否|NONE|
43+
| partitionedJoin | 是否在維表join之前先根据 設定的key 做一次keyby操作(可以減少维表的数据缓存量)|否|false|
4444

4545
--------------
46-
> 缓存策略
47-
> * NONE: 不做内存缓存
48-
> * LRU:
49-
> > cacheSize ==> 缓存的条目数量
50-
> > cacheTTLMs ==> 缓存的过期时间(ms)
46+
> 缓存策略
47+
> * NONE: 不做内存缓存
48+
> * LRU:
49+
> > cacheSize ==> 缓存的条目数量
50+
> > cacheTTLMs ==> 缓存的过期时间(ms)
5151
5252

5353
## 4.样例

‎docs/hbaseSink.md‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -28,14 +28,14 @@ hbase2.0
2828

2929
## 4.参数：
3030

31-
|参数名称|含义|是否必填|
32-
|----|---|---|
33-
|type | 表明 输出表类型[mysql|hbase|elasticsearch]|是|
34-
|zookeeperQuorum | hbase zk地址,多个直接用逗号隔开|是|
35-
|zookeeperParent | zkParent 路径|是|
36-
|tableName | 关联的hbase表名称|是|
37-
|rowKey | hbase的rowkey关联的列信息|是|
38-
|parallelism | 并行度设置|否|
31+
|参数名称|含义|是否必填|默认值|
32+
|----|---|---|-----|
33+
|type | 表明 输出表类型[mysql\|hbase\|elasticsearch]|是||
34+
|zookeeperQuorum | hbase zk地址,多个直接用逗号隔开|是||
35+
|zookeeperParent | zkParent 路径|是||
36+
|tableName | 关联的hbase表名称|是||
37+
|rowKey | hbase的rowkey关联的列信息|是||
38+
|parallelism | 并行度设置|否|1|
3939
4040

4141
## 5.样例：

‎docs/kafka09source.md‎

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -26,9 +26,7 @@ CREATE TABLE tableName(
2626
| colName | 列名称|
2727
| colType | 列类型 [colType支持的类型](colType.md)|
2828
| function(colNameX) as aliasName | 支持在定义列信息的时候根据已有列类型生成新的列(函数可以使用系统函数和已经注册的UDF)|
29-
| WATERMARK FOR colName AS withOffset( colName , delayTime ) | 标识输入流生的watermake生成规则,根据指定的colName(当前支持列的类型为Long or Timestamp)
30-
和delayTime生成waterMark 同时会在注册表的使用附带上rowtime字段(如果未指定则默认添加proctime字段);
31-
注意：添加该标识的使用必须设置系统参数 time.characteristic:EventTime; delayTime: 数据最大延迟时间(ms)|
29+
| WATERMARK FOR colName AS withOffset( colName , delayTime ) | 标识输入流生的watermake生成规则,根据指定的colName(当前支持列的类型为Long \| Timestamp) 和delayTime生成waterMark 同时会在注册表的使用附带上rowtime字段(如果未指定则默认添加proctime字段);注意：添加该标识的使用必须设置系统参数 time.characteristic:EventTime; delayTime: 数据最大延迟时间(ms)|
3230

3331
## 4.参数：
3432

‎docs/mysqlSide.md‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -47,11 +47,11 @@
4747
| partitionedJoin | 是否在維表join之前先根据 設定的key 做一次keyby操作(可以減少维表的数据缓存量)|否|false|
4848

4949
----------
50-
> 缓存策略
51-
> * NONE: 不做内存缓存
52-
> * LRU:
53-
> > cacheSize ==> 缓存的条目数量
54-
> > cacheTTLMs ==> 缓存的过期时间(ms)
50+
> 缓存策略
51+
> * NONE: 不做内存缓存
52+
> * LRU:
53+
> > cacheSize ==> 缓存的条目数量
54+
> > cacheTTLMs ==> 缓存的过期时间(ms)
5555
5656

5757
## 5.样例

‎docs/mysqlSink.md‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -28,14 +28,14 @@ CREATE TABLE tableName(
2828

2929
## 4.参数：
3030

31-
|参数名称|含义|是否必填|
32-
|----|---|---|
33-
|type |表明 输出表类型[mysql|hbase|elasticsearch]|是|
34-
|url | 连接mysql数据库 jdbcUrl |是|
35-
|userName | mysql连接用户名 |是|
36-
| password | mysql连接密码|是|
37-
| tableName | mysql表名称|是|
38-
| parallelism | 并行度设置|否|
31+
|参数名称|含义|是否必填|默认值|
32+
|----|----|----|----|
33+
|type |表明 输出表类型[mysql\|hbase\|elasticsearch]|是||
34+
|url | 连接mysql数据库 jdbcUrl |是||
35+
|userName | mysql连接用户名 |是||
36+
| password | mysql连接密码|是||
37+
| tableName | mysql表名称|是||
38+
| parallelism | 并行度设置|否|1|
3939

4040
## 5.样例：
4141
```

0 commit comments

Comments
 (0)