各位大佬:
场景描述: 利用flink监控某个目录下的文件,如果文件内数据增加(追加)了,就进行处理。
使用方法: 我现在利用ContinuousFileMonitoringFunction
作为source,采用PROCESS_CONTINUOUSLY的处理模式。
遇见的问题: 当使用这种方法时每次追加文件内容后都是全量的读取文件数据,有没有什么方法让我追加文件后只读取到追加的内容?
各位大佬:
场景描述: 利用flink监控某个目录下的文件,如果文件内数据增加(追加)了,就进行处理。
使用方法: 我现在利用ContinuousFileMonitoringFunction
作为source,采用PROCESS_CONTINUOUSLY的处理模式。
遇见的问题: 当使用这种方法时每次追加文件内容后都是全量的读取文件数据,有没有什么方法让我追加文件后只读取到追加的内容?