国产精品天干天干,亚洲毛片在线,日韩gay小鲜肉啪啪18禁,女同Gay自慰喷水

歡迎光臨散文網(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ó)家法律
紫阳县| 衡东县| 沂水县| 马边| 定边县| 噶尔县| 射洪县| 德安县| 曲靖市| 阿图什市| 郑州市| 尖扎县| 麻栗坡县| 吉木乃县| 会东县| 承德县| 宁海县| 读书| 陆丰市| 玉田县| 涿鹿县| 保康县| 麻阳| 柏乡县| 祁阳县| 辽中县| 庄浪县| 星座| 桓台县| 文化| 清苑县| 临城县| 正镶白旗| 宜黄县| 长岭县| 长泰县| 辽源市| 镇康县| 瑞安市| 凤翔县| 龙州县|