flink實戰--自定義source

Data Source簡介              數據的來源是flink程序從中讀取輸入的地方。咱們可使用StreamExecutionEnvironment.addSource（sourceFunction）將源添加到程序中。flink附帶大量預先實現好的各類讀取數據源的函數，其他的需求須要咱們經過爲非並行源去實SourceFunction接口或者爲並行源實現ParallelSourceFu

>>阅读原文<<