我正在使用 Flink 的TimeWindow
功能来执行一些计算。我正在创建一个 5 分钟Window
。但是我只想第一次创建一个小时Window
。我需要的下一个窗口是 5 分钟。
这样在第一个小时内,收集数据并对其执行我的操作。完成此操作后,每五分钟执行一次相同的操作。
我发现这可以用 a 来实现,trigger
但我不确定trigger
应该使用哪个以及如何使用。
更新:我认为甚至triggers
没有帮助,据我所知,他们只是定义触发的时间/计数window
,而不是触发第一个window
的时间。