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

?

?

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

上面第二個(gè)圖的意思是

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

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

總結(jié)

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

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