Flink GroupBy與Window的關系



不帶時間窗口的的groupby 會來一條數據進行一條數據的更新操作。這個時候結果是incrment的狀態,每次都是覆蓋(包含)了上次的結果。

image



帶時間窗口的groupby 會對時間窗口內的一批數據進行處理。這個結果是segment的狀態,與窗口個數對應。

image


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2026 CODEPRJ.COM