- 链接地址：https://blog.csdn.net/GX_0824/article/details/127158274
- 链接标题：Flink 自定义源算子_fnikgx-CSDN博客
- 所属网站：blog.csdn.net
- 被收藏次数：2908
文章浏览阅读536次。/若想要并行处理，需要实现一个ParallelSourceFunction（自定义源算子继承ParallelSourceFunction），算子并行度才可以设置多个。//ParallelSourceFunction[Event] 算子可以设置并行度。//SourceFunction[Event] 并行度必须是 1。//用标志位作为循环判断条件，不停的发送数据。//调用ctx的方法向下游发送数据。//随机生成一个event。//每隔1秒发送一条数据。//读取自定义数据源。_fnikgx
版权声明：本文发布于特牛网址导航 内容均来源于互联网 如有侵权联系删除
标签：fnikgx
