Apache Flink源碼解析之stream-source

今天咱們來解讀一下Flink stream裏的source模塊。它是整個stream的入口，也是咱們瞭解其流處理體系的入口。java SourceFunction SourceFunction是全部stream source的根接口。web 它繼承自一個標記接口（空接口）Function。算法 SourceFunction定義了兩個接口方法：apache run ： 啓動一個source，即對接一

>>阅读原文<<