flink滑动窗口输出结果的问题
大家好， 我现在的场景需求是，窗口size是1个小时，每分钟触发统计一次结果。比如现在是10点钟，则统计9点到10点的结果。 下一分钟则在10:01分时触发统计9：01到10：01的结果。
如果用Sliding window, 比如.timeWindow(Time.hours(1L), Time.minutes(1))， 则会输出60/1=60个结果集，这不是我想要的结果，我只想要当前时间往前一个小时的结果。
除了在window function api做逻辑过虑外，还有什么方法可以实现这种场景？
滚动窗口的话不适合，它每次是输出整点的，比如从9点到10点，然后就跳到10点到11点，也不符合我的业务要求。*来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
对的是我！只要sliding出来才满足你每分钟执行的滑动要求吧？至于你只要最早/新的某一条，你可以从window groupby得出的流再次group by然后再用window时间筛选你要的数据。*来自志愿者整理的flink邮件归档
2021-12-08 17:06:03赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
