题目描述： 在Flink流计算中开发自定义Source，实现循环产生从1开始递增+1的数字，然后把这个结果数据直接打印到控制台即可。
效果： 通过自定义Source实现产生从1开始的递增数字
任务要求:
1：Flink中的自定义Source分为支持单并行度和多并行度，在这里使用支持单并行度的自定义Source
2：使用Scala代码开发
任务提示、思路分析：
1：查阅Flink相关资料，实现自定义Source的开发
2：考虑使用SourceFunction
登录后即可发布作业，立即登录
正在编辑内容
我的作业
全部作业
未解锁课程不能发布信息~
解锁课程
在线咨询
领取优惠
免费试听
领取大纲