Apache Flink源碼解析之stream-sink

上一篇咱們談論了Flink stream source，它做爲流的數據入口是整個DAG（有向無環圖）拓撲的起點。那麼與此對應的，流的數據出口就是跟source對應的Sink。這是咱們本篇解讀的內容。java SinkFunction 跟SourceFunction對應，Flink針對Sink的根接口被稱爲SinkFunction。繼承自Function這一標記接口。SinkFunction接口只提

>>阅读原文<<