题目描述: 在Flink批处理中创建自定义Source,产生一批单词数据即可,最终将结果打印到控制台上。
效果: 通过自定义Source实现产生一批单词数据
任务要求:
1:使用Scala代码开发Flink批处理中的自定义Source
任务提示、思路分析:
1:查阅Flink相关资料,实现自定义Source的开发
2:考虑使用RichInputFormat
登录后即可发布作业,立即登录
正在编辑内容
我的作业
全部作业
未解锁课程不能发布信息~
解锁课程
购课补贴联系客服咨询优惠详情
慕课网APP您的移动学习伙伴
扫描二维码关注慕课网微信公众号
在线咨询
领取优惠
免费试听
领取大纲