Skip to content

Commit 2df63ae

Browse files
修改elasticsearch6-sink文档
1 parent 18f0c62 commit 2df63ae

File tree

1 file changed

+10
-4
lines changed

1 file changed

+10
-4
lines changed

docs/elasticsearch6Sink.md

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -7,9 +7,12 @@ CREATE TABLE tableName(
77
type ='elasticsearch6',
88
address ='ip:port[,ip:port]',
99
cluster='clusterName',
10-
estype ='esType',
10+
esType ='esType',
1111
index ='index',
1212
id ='num[,num]',
13+
authMesh = 'true',
14+
userName = 'userName',
15+
password = 'password',
1316
parallelism ='1'
1417
)
1518
```
@@ -27,11 +30,11 @@ CREATE TABLE tableName(
2730
## 4.参数:
2831
|参数名称|含义|是否必填|默认值|
2932
|----|---|---|----|
30-
|type|表明 输出表类型[mysq|hbase|elasticsearch]|||
33+
|type|表明 输出表类型[elasticsearch6]|||
3134
|address | 连接ES Transport地址(tcp地址)|||
3235
|cluster | ES 集群名称 |||
3336
|index | 选择的ES上的index名称|||
34-
|estype | 选择ES上的type名称|||
37+
|esType | 选择ES上的type名称|||
3538
|id | 生成id的规则(当前是根据指定的字段pos获取字段信息,拼接生成id;|||
3639
| |若id为空字符串或索引都超出范围,则随机生成id值)|||
3740
|authMesh | 是否进行用户名密码认证 || false|
@@ -48,8 +51,11 @@ CREATE TABLE MyResult(
4851
type ='elasticsearch',
4952
address ='172.16.10.47:9500',
5053
cluster='es_47_menghan',
51-
estype ='type1',
54+
esType ='type1',
5255
index ='xc_es_test',
56+
authMesh = 'true',
57+
userName = 'elastic',
58+
password = 'abc123',
5359
id ='0,1',
5460
parallelism ='1'
5561
)

0 commit comments

Comments
 (0)