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

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

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

任务要求:

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

任务提示、思路分析:

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

2:考虑使用RichInputFormat

去发布

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

我的作业

全部作业

意见反馈 帮助中心 APP下载
官方微信

在线咨询

领取优惠

免费试听

领取大纲

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