flink實戰—數據寫入ES（ElasticSearch）

簡介         Flink內置了Elasticsearch Connector用於對ES進行數據的操做，裏面主要的類是ElasticsearchSink，使用時咱們須要實現裏面的抽象方法，自定義本身的邏輯。html 版本說明：java ES版本：6.3.2    flink 1.6.1 sql 須要添加的依賴  <dependency> <groupId>org.apache.fl

>>阅读原文<<