使用Elasticsearch Connector建表的局限性是什么？
使用Elasticsearch Connector建表的局限性是什么？
写回答
-
Elasticsearch Connector 只实现了 Sink，所以只能往 ES 里去写，而不能从里面读。它的 Connector 类型可以指定成 ES6 或者 ES7；Hosts 就是指定的 ES 的各个节点，通过域名加端口号的形式；Index 是指定写 ES 的 index，类似于传统数据库当中的一张表；Document Type 类似于传统数据库的表里面的某一行，不过在ES7 里不需要指定。
ES 的 Sink 支持 append 和 upsert 两种模式，如果这张 ES 表在定义的时候指定了 PK，那么 Sink 就会以 upsert 模式工作，如果没有指定 PK，就以append模式来工作，但是像 ROW和MAP等类型是不能作为PK的。
使用 ES 也需要指定额外的依赖，针对不同的 ES 版本添加 ES Connector。
资料来源：《Apache Flink 必知必会》，下载链接：https://developer.aliyun.com/topic/download?id=1189
2021-11-17 18:29:17赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
