自定義 ElastisSearch Sink
1.添加Maven依賴 <dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-elasticsearch6_2.11</artifactId>
<version>1.9.1</version>
</dependency> 2.編寫EsSink工具類 import lombok.extern.s
相關文章
- 1. flink自定義 sink
- 2. Redis Sink 自定義
- 3. flink自定義source與自定義sink
- 4. 自定義Flume Sink：ElasticSearch Sink
- 5. flume自定義source，sink
- 6. Flink 自定義Sink 之 寫入HDFS
- 7. 5.如何自定義 Data Sink ？
- 8. Flink的sink實戰之四：自定義
- 9. Flume自定義Sink到MySQL數據庫
- 10. Flink:RetractStreamTableSink 自定義sink寫數據到Phoenix
- 更多相關文章...
- • 自定義TypeHandler - MyBatis教程
- • MySQL自定義函數（CREATE FUNCTION） - MySQL教程
- • RxJava操作符（十）自定義操作符
- • SpringBoot中properties文件不能自動提示解決方法
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
歡迎關注本站公眾號,獲取更多信息
