题目描述:
在Flink批处理中创建自定义Source,产生一批单词数据即可,最终将结果打印到控制台上。
效果:
通过自定义Source实现产生一批单词数据
任务要求:
1:使用Scala代码开发Flink批处理中的自定义Source
任务提示、思路分析:
1:查阅Flink相关资料,实现自定义Source的开发
2:考虑使用RichInputFormat
题目描述:
在Flink批处理中创建自定义Source,产生一批单词数据即可,最终将结果打印到控制台上。
效果:
通过自定义Source实现产生一批单词数据
任务要求:
1:使用Scala代码开发Flink批处理中的自定义Source
任务提示、思路分析:
1:查阅Flink相关资料,实现自定义Source的开发
2:考虑使用RichInputFormat