ES
更新时间：2020-08-17
ES DDL
CREATE TABLE sink_es_table (
`field01` STRING,
`field02` BIGINT,
`field03` FLOAT,
`field04` BINARY,
`field05` INT,
`field06` TINYINT,
`field07` BOOLEAN,
`field08` DATA,
`field09` DOUBLE,
`field10` SMALLINT
) WITH (
'connector.type' = 'ES',
'connector.version' = '6.5.3',
'connector.cluster-id' = 'xxxxxxxxxxxxx',
'connector.host' = '192.168.11.208',
'connector.port' = '8200',
'connector.index' = 'bsc_test',
'connector.document-type' = 'doc_type',
'connector.username' = 'superuser',
'connector.password' = 'bsc_1234'
);
ES 参数设置
| 名称 | 简称 | 是否必填 | 用例 | SPARK | FLINK | 说明 |
|---|---|---|---|---|---|---|
| connector.type | type | Y | ES |
Y | Y | 服务类型 |
| connector.version | version | 6.5.3 |
Y | ES 集群版本 | ||
| connector.cluster-id | cluster-id | Y | xxxxxxxxxxx |
Y | Y | ES 集群ID |
| connector.host | host | Y | 192.168.11.208 |
Y | Y | ES 集群机器 |
| connector.port | port | Y | 8200 |
Y | Y | ES 集群端口 |
| connector.index | index | Y | bsc_test |
Y | Y | ES 创建的索引名称 |
| connector.document-type | document-type | Y | doc_type |
Y | Y | ES 创建的索引类型 |
| connector.username | username | Y | superuser |
Y | Y | ES 用户名称 |
| connector.password | password | Y | bsc_1234 |
Y | Y | ES 用户密码 |
