特牛生活网

Flink Table 将Stream追加写入Elasticsearch_flink elasticsearch upsert 局部-CSDN博客

网友收藏
文章浏览阅读2.2k次。Flink Table 将Stream追加写入ElasticsearchFlink Table提供了多种方式,写入ElasticSearch。一种是Connector的方式连接ElasticSearch,另一种是通过Sink的方式。下面分别介绍2种方式。一、Connector的方式写入Elasticsearchpublic class SqlSinkElasticSearchStream {..._flink elasticsearch upsert 局部