从你的描述来看，你说的貌似就是sliding window呀。 9-10，9.01-10.01...
[email protected] <[email protected]> 于2021年1月15日周五 下午5:45写道： > 大家好， 我现在的场景需求是，窗口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点，也不符合我的业务要求。 > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/
