【学习任务】项目任务-在Flink批处理中创建自定义Source
我要参与
【学习任务】项目任务-在Flink批处理中创建自定义Source
学习任务 829
等29人参与
来源: 第20周 / 大数据工程师

题目描述:
在Flink批处理中创建自定义Source,产生一批单词数据即可,最终将结果打印到控制台上。

效果:
通过自定义Source实现产生一批单词数据

任务要求:

1:使用Scala代码开发Flink批处理中的自定义Source

任务提示、思路分析:

1:查阅Flink相关资料,实现自定义Source的开发

2:考虑使用RichInputFormat

去发布

登录后即可发布作业,立即

我的作业

全部作业

微信客服

购课补贴
联系客服咨询优惠详情

帮助反馈 APP下载

慕课网APP
您的移动学习伙伴

公众号

扫描二维码
关注慕课网微信公众号

在线咨询

领取优惠

免费试听

领取大纲

扫描二维码,添加
你的专属老师