滑动窗口的应用是什么场景呢？

滚动窗口可以理解是流处理，但是滑动窗口有时候会有重复消费数据的问题吧，想不到项目中哪里会用到滑动窗口。

幕布斯5216845 2021-10-05

源自：Flink高级进阶之路 1-2 TimeWindow的使用

14

收起

1回答

徐老师回答被采纳获得+3积分 2021-10-05 11:34:36

滑动窗口有时候会有重复消费数据的问题吧，不能说是重复消费，是重复计算了之前窗口内的数据。

滑动窗口工作中很少用，因为滑动窗口会重复计算数据，所以从结果层面只能看一个趋势。

如果是想要出一个用户实时新增在线数量的折线图，此时可以考虑使用滑动窗口，这样可以避免某一个时间点没有数据导致折线图忽高忽低，折线图看起来会比较平顺，这样便于看一个趋势

幕布斯5216845 提问者 #1

之前的flink程序没有使用window也能跑呀，是默认了滚动窗口吗？
加了window就是规定了消费的规则，如果没有重复计算的需求，感觉不加window也没啥问题呀？

2021-10-05 11:40:51
幕布斯5216845 提问者 #2

还有一个疑问，flink中的这个window，跟SparkStreaming中的batch，感觉差不多啊，都是一个区间内的数据，flink的实时计算有点没区分出来。

2021-10-05 12:49:00
幕布斯5216845 提问者 #3

第一个疑问好像没展示出来：

之前的flink程序没有设置到windows，是有默认的window值？还是window就没有设置呢，是某些特殊的场景需要设置window？
flink如果走的是流计算，并且没有重复计算的需求，来一条数据就计算一条，感觉没必要设置window啊？

2021-10-05 12:51:03

点开查看后面1条评论

相似问题

throw he throws的应用场景疑问

滑动窗口0到5秒的时间窗口访问量问题

窗口的问题

上下滑动与左右滑动

我的代码怎么没有反应

登录后可查看更多问答，登录/注册

大数据工程师

参与学习 1173 人
提交作业 6122 份
解答问题 1177 个

不用Java初级内容充数！不用与大数据岗位无关内容占课时！我们做的就是“精华版”大数据课程

本课精华内容

问答作业

老师，每个比较大的文件都会分割成块保存在DataNode中，那就说一个datanode坏了导致整个文件不可用，这样不就减低了可靠性吗？

56 2

对多个executor并行处理，对数据进行去重，这样会不会有重复数据

32 1

数据倾斜问题

78 5

并行度调优疑问

29 9

yum install -y ntpdate执行报错

19 22

查看更多本课问答

请稍等 ...

购课补贴
联系客服咨询优惠详情

帮助反馈 APP下载

慕课网APP
您的移动学习伙伴

扫描二维码
关注慕课网微信公众号