代码拉取完成，页面将自动刷新
CREATE TABLE tableName(
colName colType,
bb INT
)WITH(
type ='elasticsearch',
address ='ip:port[,ip:port]',
cluster='clusterName',
estype ='esType',
index ='index',
id ='num[,num]',
parallelism ='1'
)
ES5
| 参数名称 | 含义 |
|---|---|
| tableName | 在 sql 中使用的名称;即注册到flink-table-env上的名称 |
| colName | 列名称 |
| colType | 列类型 colType支持的类型 |
| 参数名称 | 含义 | 是否必填 | 默认值 |
|---|---|---|---|
| type | 表明 输出表类型[mysql|hbase|elasticsearch] | 是 | |
| address | 连接ES Transport地址(tcp地址) | 是 | |
| cluster | ES 集群名称 | 是 | |
| index | 选择的ES上的index名称 | 是 | |
| estype | 选择ES上的type名称 | 是 | |
| id | 生成id的规则(当前是根据指定的字段pos获取字段信息,拼接生成id) | 是 | |
| parallelism | 并行度设置 | 否 | 1 |
CREATE TABLE MyResult(
aa INT,
bb INT
)WITH(
type ='elasticsearch',
address ='172.16.10.47:9500',
cluster='es_47_menghan',
estype ='type1',
index ='xc_es_test',
id ='0,1',
parallelism ='1'
)
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手