网站介绍：文章浏览阅读3.5k次。实现无并行度的自定义Source1、run方法重写（主要的方法）：启动一个source注意：继承接口 SourceFunction的时候需要指定泛型，否则会报错如：SourceFunction，即run中产生的数据类型SourceFunction 和 SourceContext 都需要指定在大部分情况下，都需要在这个run方法中实现一个循环，就可以循环产生数据传入参数 (S..._datasource datastream
- 链接地址：https://blog.csdn.net/hongzhen91/article/details/90055041
- 链接标题：【03】Flink 之 DataStream API（一）：Data Source 和 自定义Source_datasource datastream-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：3832
- 网站标签：datasource datastream
