问题描述
我是一只新的蜜蜂,面临着一些需要解决以下用例的挑战
用例描述:
我会在某个文件夹中的每一天收到一个带有时间戳的 csv 文件,比如 input。文件格式为 file_name_dd-mm-yy-hh-mm-ss.csv。
现在我的 flink 管道将逐行读取这个 csv 文件,并将其写入我的 Kafka 主题。
一旦管道读取了整个文件,则需要将该文件移动到另一个文件夹(例如历史文件夹),以便我可以将新文件的输入文件夹保持为空。
我用谷歌搜索了很多,但没有找到任何东西,所以你能指导我实现这一点吗。
如果还有什么需要,请告诉我。
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)