flink基础之window_flink选择题

作者：Guff_9hys | 2024-07-11 20:28:35

踩

flink选择题

　　flink会把数据分成不同的窗口，然后进行汇总和统计。

　　flink的窗口分为timeWindow, countWindow, sessionWindow, gapWindow。

　　timeWindow分为基于时间的滚动窗口和滑动窗口。

　　举个例子，统计每60秒的访问量需要的就是滚动窗口；每5分钟统计一次一个小时内的访问量或者获取访问前几的top值，这个时候就需要用到滑动窗口了。

　　如果还不明白，看下面的图，图片来源flink官网的blog里。有一个传感器一直录入值，然后需要统计每个窗口里边的汇总值，效果就是这个样子。

　　再来看一下滑动窗口的图，假如sensor给到的是15秒钟汽车穿过马路的数量，现在需要每30秒统计1分钟的穿过马路的数量。第一次 9+6+8+4 = 22，然后往右边滑两个数，8+4+7+3=22, 然后再往右边滑两个数，依此类推。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/Guff_9hys/article/detail/811511