无码av一区二区三区无码,在线观看老湿视频福利,日韩经典三级片,成 人色 网 站 欧美大片在线观看

歡迎光臨散文網(wǎng) 會(huì)員登陸 & 注冊(cè)

Flink窗口函數(shù):滑動(dòng)窗口使用方法詳解

2023-07-31 10:49 作者:ingemar-  | 我要投稿

滑動(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)的方法初始化窗口。


Flink窗口函數(shù):滑動(dòng)窗口使用方法詳解的評(píng)論 (共 條)

分享到微博請(qǐng)遵守國(guó)家法律
扎囊县| 利辛县| 潼南县| 东兰县| 澄迈县| 石嘴山市| 汉阴县| 家居| 凌云县| 武冈市| 金寨县| 威信县| 兴宁市| 枝江市| 长岭县| 彩票| 西充县| 青岛市| 赣榆县| 屏山县| 新化县| 湘潭县| 金沙县| 雅江县| 乐山市| 宜章县| 贺州市| 密山市| 绍兴县| 北宁市| 青浦区| 宁安市| 北碚区| 新平| 上栗县| 尖扎县| 洛隆县| 徐闻县| 大足县| 新河县| 泽库县|