Flink Table 將Stream追加寫入Elasticsearch

Flink Table 將Stream追加寫入Elasticsearch Flink Table提供了多種方式,寫入ElasticSearch。一種是Connector的方式鏈接ElasticSearch,另外一種是經過Sink的方式。下面分別介紹2種方式。java 1、Connector的方式寫入Elasticsearch public class SqlSinkElasticSearchStr
相關文章
相關標籤/搜索