Flink窗口函數(shù):滑動(dòng)窗口使用方法詳解
滑動(dòng)窗口以一個(gè)步長(zhǎng)(Slide)不斷向前滑動(dòng),窗口的長(zhǎng)度固定。
使用時(shí),我們要設(shè)置Slide和Size。Slide的大小決定了Flink以多快的速度來創(chuàng)建新的窗口,Slide較小,窗口的個(gè)數(shù)會(huì)很多。Slide小于窗口的Size時(shí),相鄰窗口會(huì)重疊,一個(gè)元素會(huì)被分配到多個(gè)窗口;Slide大于Size,有些元素可能被丟掉。

跟前面介紹的一樣,我們使用Time類中的時(shí)間單位來定義Slide和Size,也可以設(shè)置offset。
同樣,timeWindow是一種縮寫,根據(jù)執(zhí)行環(huán)境中設(shè)置的時(shí)間語義來選擇相應(yīng)的方法初始化窗口。
