上传者: 41773806
|
上传时间: 2022-02-21 19:11:27
|
文件大小: 4KB
|
文件类型: ZIP
该实例的处理过程是通过 Flink 对文件存储系统里的数据进行离线批处理,统计指定文件下的单词数,并将统计结果存储到其他文件下。
该实例业务实现过程如下:
- 首先使用 `filesystem` 作为连接器,按照指定的 `csv` 格式来批量地读取指定路径的文件或文件夹,以此创建源数据表。
- 然后,在 Flink 中执行批处理实例逻辑,完成批处理任务。
- 最后,使用 `filesystem` 连接器,将处理后结果写入目标文件或文件夹内,构建结果表。