Flink WaterMark 詳解及結合 WaterMark 處理延遲數據

在 3.1 節中講解了 Flink 中的三種 Time 和其對應的使用場景,然後在 3.2 節中深入的講解了 Flink 中窗口的機制以及 Flink 中自帶的 Window 的實現原理和使用方法。如果在進行 Window 計算操作的時候,如果使用的時間是 Processing Time,那麼在 Flink 消費數據的時候,它完全不需要關心的數據本身的時間,意思也就是說不需要關心數據到底是延遲數據
相關文章
相關標籤/搜索