大家好, 我现在的场景需求是,窗口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/

回复