[flink-014]Sink和ES6的ElasticsearchSink_elasticsearchsinkbase-CSDN博客

网站介绍:Sink,水池。Flink的计算结果,最终传给Sink落地存储。Sink支持多种存储系统,包括数据库和消息队列,比如JDBC、Kaffka、Elasticsearch、Hbase....从源头说起。接口Function,位于Function.java,空接口,是所有用户自定义函数的根接口。接口SinkFunction,继承Function,是所有用户自定义Sink函数的顶层接口。它..._elasticsearchsinkbase