创建ElasticSearch（ES）结果表

2018-11-13 659 收藏

创建 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业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

数据结果表概述

实时计算 Flink使用CREATE TABLE作为输出结果数据的格式定义，同时定义数据如何写入到目的数据存储。实时计算有Append类型和Update类型。 Append类型：如果输出存储是日志系统或消息系统，或未定义主键的RDS，则流的输出结果都会以追加的方式写入存储中，而不会修改存储中原有的数据。 Update类型：如果输出存储是声明了主键（PRIMARY KEY）的数据库（例如RDS、HBase），流的输出结果会发生以下两种情况。 如果根据主键查询数据在数据库中不存在，则会将该数据插入到数据库。 如果根据主键查询数据在数据库中存在，则会根据主键更新数据。 语法 CREATE TABLE tableName (columnName dataType [, columnName dataType ]*) [ WITH (propertyName=propertyValue [, propertyName=propertyValue ]*) ]; 示例 create table rds_output( id int, len int, content VARCHAR, primary...

2018-11-14

589

上一篇

创建云数据库 Hbase结果表

本页目录 创建云数据库 Hbase结果表 WITH参数 创建云数据库 Hbase结果表 create table liuxd_user_behavior_test_front ( row_key varchar, from_topic varchar, origin_data varchar, record_create_time varchar, PRIMARY KEY (row_key) ) with ( type = 'cloudhbase', zkQuorum = 'xxx' columnFamily = 'xxx', tableName = 'xxx', batchSize = '500' ) 注意： primary key支持定义多个字段。多个字段会按照rowkeyDelimiter(默认为（:）)拼接起来作为rowkey。 hbase做撤回删除操作时，如果column定义了多版本，会把所有版本的值清空。 WITH参数 参数 注释说明 备注 zkQuorum hbase集群配置的zk地址 可以在hbase-site.xml文件中找到hbase.zookeeper.quoru...

2018-11-14

631

下一篇

相关文章

发表评论

发表

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

时间: 2025-12-03 大小: 4.36MB 下载: 23次

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

时间: 2025-12-12 大小: 211.28KB 下载: 54次

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

时间: 2026-01-27 大小: 1MB 下载: 5次

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。

时间: 2025-12-03 大小: 9.84MB 下载: 39次