Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
Flink中readFile中如何只读取增量文件
Classic
List
Threaded
♦
♦
Locked
1 message
zhangjunjie1130@163.com
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
Flink中readFile中如何只读取增量文件
您好:
现在使用env.readFile的参数中,watchType只有两种参数:
FileProcessingMode.PROCESS_CONTINUOUSLY - 当输入路径下有文件被修改,整个路径下内容将会被重新处理
FileProcessingMode.PROCESS_ONCE - 只扫描一次,便退出。因此这种模式下输入数据只读取一次
想问一下一种方法,只加载文件中的增量内容?
[hidden email]
Free forum by Nabble
Edit this page