flink实战--自定义source

Data Source简介              数据的来源是flink程序从中读取输入的地方。咱们可使用StreamExecutionEnvironment.addSource（sourceFunction）将源添加到程序中。flink附带大量预先实现好的各类读取数据源的函数，其他的需求须要咱们经过为非并行源去实SourceFunction接口或者为并行源实现ParallelSourceFu

>>阅读原文<<