Flink通过实现SourceFunction接口来自定义非并行的Source，实现ParallelSourceFunction接口来自定义并行的Source。Flink通过实现SourceFunction接口来自定义非并行的Source，
阅读背景：
Flink自定义生成测试数据的Source_upupfeng的博客_flink 测试数据
来源：互联网
分享到：
