网站介绍:Sink,水池。Flink的计算结果,最终传给Sink落地存储。Sink支持多种存储系统,包括数据库和消息队列,比如JDBC、Kaffka、Elasticsearch、Hbase....从源头说起。接口Function,位于Function.java,空接口,是所有用户自定义函数的根接口。接口SinkFunction,继承Function,是所有用户自定义Sink函数的顶层接口。它..._elasticsearchsinkbase
- 链接地址:https://blog.csdn.net/u011539200/article/details/100134122
- 链接标题:[flink-014]Sink和ES6的ElasticsearchSink_elasticsearchsinkbase-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:7063
- 网站标签:elasticsearchsinkbase