将已经处理过的文件从一个文件夹移动到 flink 中的另一个文件夹

问题描述

我是一只新的蜜蜂,面临着一些需要解决以下用例的挑战

用例描述:

我会在某个文件夹中的每一天收到一个带有时间戳的 csv 文件,比如 input。文件格式为 file_name_dd-mm-yy-hh-mm-ss.csv。

现在我的 flink 管道将逐行读取这个 csv 文件,并将其写入我的 Kafka 主题

一旦管道读取了整个文件,则需要将该文件移动到另一个文件夹(例如历史文件夹),以便我可以将新文件的输入文件夹保持为空。

我用谷歌搜索了很多,但没有找到任何东西,所以你能指导我实现这一点吗。

如果还有什么需要,请告诉我。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)