Apache Flink 零基礎入門（十五）Flink DataStream編程（如何自定義DataSource）

數據源能夠經過StreamExecutionEnvironment.addSource(sourceFunction)方式來建立，Flink也提供了一些內置的數據源方便使用，例如readTextFile(path) readFile()，固然，也能夠寫一個自定義的數據源（能夠經過實現SourceFunction方法，可是沒法並行執行。或者實現能夠並行實現的接口ParallelSourceFunct

>>阅读原文<<