不帶時間窗口的的groupby 會來一條數(shù)據(jù)進(jìn)行一條數(shù)據(jù)的更新操作。這個時候結(jié)果是incrment的狀態(tài)，每次都是覆蓋（包含）了上次的結(jié)果。

?

?

帶時間窗口的groupby 會對時間窗口內(nèi)的一批數(shù)據(jù)進(jìn)行處理。這個結(jié)果是segment的狀態(tài)，與窗口個數(shù)對應(yīng)。

上面第二個圖的意思是

根據(jù)時間間隔把數(shù)據(jù)隔開成好幾份，

然后每份內(nèi)部再按照user進(jìn)行聚合(統(tǒng)計上化簡)

總結(jié)

以上是生活随笔為你收集整理的Flink的Group by window图示(转载)的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。