flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "zhangjunjie1130@163.com" <zhangjunjie1...@163.com>
Subject Flink中readFile中如何只读取增量文件
Date Mon, 15 Jul 2019 09:22:43 GMT
您好:
        现在Flink使用env.readFile的参数中,watchType只有两种参数:
            FileProcessingMode.PROCESS_CONTINUOUSLY - 当输入路径下有文件被修改,整个路径下内容将会被重新处理
            FileProcessingMode.PROCESS_ONCE - 只扫描一次,便退出。因此这种模式下输入数据只读取一次
         想问一下一种方法,只加载文件中的增量内容?



zhangjunjie1130@163.com
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message