最美情侣中文字幕电影,在线麻豆精品传媒,在线网站高清黄,久久黄色视频

歡迎光臨散文網(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ó)家法律
辽阳县| 平塘县| 屏东市| 阳新县| 竹北市| 云龙县| 平武县| 冕宁县| 惠来县| 惠水县| 伽师县| 梧州市| 邛崃市| 东山县| 彰武县| 诸城市| 浮山县| 榕江县| 合肥市| 昔阳县| 天峨县| 雷州市| 神农架林区| 舞阳县| 六安市| 尖扎县| 舒城县| 彝良县| 郸城县| 慈溪市| 宜宾县| 温州市| 长宁县| 新乐市| 龙泉市| 广南县| 阳山县| 辉南县| 商河县| 合川市| 会宁县|