【Flink】Flink WindowOperator大概工作流程

1.概述 首先來了一條數據，那麼我們要判斷這個元素是歸屬到哪個window了，因爲一個數據可能屬於多個window，所以這個可能給你的是多個window的序列。 window的計算一定是根據keyBy來計算的。所以要算這個元素的key是什麼 然後遍歷所有的window 判斷這個數據是不是延遲了，如果延遲了，比如這個窗口都過期了，窗口都不存在了，那麼就不處理，我覺得這裏可以輸出到outputTag

>>阅读原文<<