您现在的位置是:首页 > 文章详情

创建ElasticSearch(ES)结果表

日期:2018-11-13点击:585

创建 ElasticSearch 结果表

注意:本文档只适合独享模式下使用。

ElasticSearch 结果表的实现使用 REST API,理论上兼容 ElasticSearch 的各个版本。以下将 ElasticSearch 简称为 ES。

ES 需要定义的 DDL 如下:

 
 
  1. create table es_stream_sink(
  2. field1 long,
  3. field2 varbianary,
  4. field3 varchar
  5. ) with (
  6. type ='elasticsearch',
  7. endPoint = 'http://127.0.0.1:9211',
  8. accessId = 'abcd',
  9. accessKey = 'efgh',
  10. index = 'mockIdx',
  11. typeName = 'mockType'
  12. ...
  13. );

WITH参数

通用配置:

参数 注释说明 默认值 Required
endPoint server 地址,例:http://127.0.0.1:9211
accessId 访问实例 id
accessKey 访问实例密钥
index 索引名称,类似于数据库 DB 的概念
typeName type 名称,类似于数据库 table 的概念
bufferSize 分 batch 写入的 records 条数 1000
maxRetryTimes 异常重试次数 30
timeout 读超时(ms) 600000
discovery 是否开启节点发现,如果开启客户端会 5 分钟刷新一次 server list false
compression 是否使用 GZIP 压缩 request bodies true
multiThread 是否开启 JestClient 多线程 true
ignoreWriteError 是否忽略写入异常 false
settings 创建 index 的 settings 配置 /
本文转自实时计算—— 创建ElasticSearch(ES)结果表
原文链接:https://yq.aliyun.com/articles/669186
关注公众号

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。

持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。

文章评论

共有0条评论来说两句吧...

文章二维码

扫描即可查看该文章

点击排行

推荐阅读

最新文章