flink增量讀文本數據

以下代碼能夠實現增量從文件地址讀數據，讀完一次以後，若你對文件增長了數據，它會相應的讀出來。java 方法內有三個屬性,分別是WatchType.ONLY_NEW_FILES：處理整個文件，PROCESS_ONLY_APPENDED只處理相應的增長部分，REPROCESS_WITH_APPENDED ：當文件內容增長了以後會從新處理整個文件。apache 在新的flink版本里面，只有兩種模式了：

>>阅读原文<<