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

歡迎光臨散文網(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ó)家法律
苍梧县| 贞丰县| 中西区| 衡阳县| 营山县| 大邑县| 威远县| 浏阳市| 岳阳县| 遂平县| 永春县| 舟山市| 南京市| 乾安县| 仙游县| 桦南县| 永和县| 南投县| 南木林县| 蓬溪县| 内丘县| 富平县| 武汉市| 永吉县| 拜城县| 吉安市| 大兴区| 自治县| 福州市| 德令哈市| 娄底市| 无极县| 清远市| 新巴尔虎右旗| 云和县| 裕民县| 余干县| 个旧市| 克什克腾旗| 左权县| 景德镇市|