Flink中readFile中如何只读取增量文件

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Flink中readFile中如何只读取增量文件

zhangjunjie1130@163.com
您好:
        现在使用env.readFile的参数中,watchType只有两种参数:
            FileProcessingMode.PROCESS_CONTINUOUSLY - 当输入路径下有文件被修改,整个路径下内容将会被重新处理
            FileProcessingMode.PROCESS_ONCE - 只扫描一次,便退出。因此这种模式下输入数据只读取一次
         想问一下一种方法,只加载文件中的增量内容?



[hidden email]