Flink Table 将Stream追加写入Elasticsearch

Flink Table 将Stream追加写入Elasticsearch Flink Table提供了多种方式,写入ElasticSearch。一种是Connector的方式链接ElasticSearch,另外一种是经过Sink的方式。下面分别介绍2种方式。java 1、Connector的方式写入Elasticsearch public class SqlSinkElasticSearchStr
相关文章
相关标签/搜索