创建ElasticSearch（ES）结果表

2018-11-13 711 收藏

创建 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-13

635

上一篇

创建云数据库 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-13

677

下一篇

相关文章

发表评论

发表

资源下载

更多资源

腾讯云软件源

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

时间: 2026-04-11 大小: 1MB 下载: 9次

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

时间: 2025-12-17 大小: 5MB 下载: 1次

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

时间: 2026-04-12 大小: 1.42GB 下载: 4次

WebStorm

WebStorm 是jetbrains公司旗下一款JavaScript 开发工具。目前已经被广大中国JS开发者誉为“Web前端开发神器”、“最强大的HTML5编辑器”、“最智能的JavaScript IDE”等。与IntelliJ IDEA同源，继承了IntelliJ IDEA强大的JS部分的功能。

时间: 2025-12-13 大小: 249.54MB 下载: 22次