Apache Flink源码解析之stream-source

今天咱们来解读一下Flink stream里的source模块。它是整个stream的入口，也是咱们了解其流处理体系的入口。java SourceFunction SourceFunction是全部stream source的根接口。web 它继承自一个标记接口（空接口）Function。算法 SourceFunction定义了两个接口方法：apache run ： 启动一个source，即对接一

>>阅读原文<<