翻滾計(jì)數(shù)窗口（無(wú)重疊數(shù)據(jù)）

按個(gè)數(shù)進(jìn)行統(tǒng)計(jì)

案例

每隔5條統(tǒng)計(jì)數(shù)據(jù)，分別統(tǒng)計(jì)

1.全量數(shù)字之和

2.分組后每個(gè)鍵對(duì)應(yīng)的數(shù)字之和

參考代碼

滑動(dòng)計(jì)數(shù)窗口（有重疊數(shù)據(jù)）

呼吁案例修改為：窗口長(zhǎng)度是10，滑動(dòng)長(zhǎng)度是3

小結(jié)

統(tǒng)計(jì)窗口和時(shí)間窗口在滑動(dòng)方面的功能一致，只是計(jì)量單位不同，一個(gè)是時(shí)間一個(gè)是數(shù)據(jù)條數(shù)。

要注意的是，對(duì)于分流后的數(shù)據(jù)進(jìn)行窗口操作，統(tǒng)計(jì)窗口是每個(gè)組達(dá)到規(guī)定的數(shù)據(jù)條數(shù)后才會(huì)被觸發(fā)

而時(shí)間窗每個(gè)組觸發(fā)的點(diǎn)是一致的。這一點(diǎn)要注意。