本文为您介绍如何创建实时计算ElasticSearch(ES)结果表
ElasticSearch结果表的实现使用REST API,理论上兼容ElasticSearch的各个版本实时计算支持使用ES作为结果输出。示例代码如下
-
full
更新模式下,新增的doc
会完全覆盖已存在的doc
-
inc
更新模式下,会依据输入的字段值更新对应的字段
说明 如果您通过Kibana插件操作ES,请填写Kibana登录ID |
说明 如果您通过Kibana插件操作ES,請填写Kibana登录密码 |
索引名称,类似于数据库Database的名称 |
Type名称,类似于数据库的Table名称 |
流入多少条数据后开始去重。 |
是否开启节点发现如果開启,客户端每5分钟刷新一次Server List |
指定主键(PRIMARY KEY)后的更新模式。 |
动态索引相关WITH参数
- 仅实时计算2.2.7及以上版本支持动态索引功能
- 当开启动态索引后,基本配置中的
index
名称会作为后续创建索引的统一AliasAlias和索引为一对多关系。 - 对于单个的真实索引可使用Index API进行修改但对于Alias只支持
get
功能。若需要更新Alias请参见。