Apache Flink 零基础入门（十五）Flink DataStream编程（如何自定义DataSource）

数据源能够经过StreamExecutionEnvironment.addSource(sourceFunction)方式来建立，Flink也提供了一些内置的数据源方便使用，例如readTextFile(path) readFile()，固然，也能够写一个自定义的数据源（能够经过实现SourceFunction方法，可是没法并行执行。或者实现能够并行实现的接口ParallelSourceFunct

>>阅读原文<<