Apache Flink源码解析之stream-sink

上一篇咱们谈论了Flink stream source,它做为流的数据入口是整个DAG(有向无环图)拓扑的起点。那么与此对应的,流的数据出口就是跟source对应的Sink。这是咱们本篇解读的内容。java SinkFunction 跟SourceFunction对应,Flink针对Sink的根接口被称为SinkFunction。继承自Function这一标记接口。SinkFunction接口只提
相关文章
相关标签/搜索