Apache在特定的开始和结束时间闪烁窗口



我有一个用例,我想用预先确定的开始时间和结束时间来计算窗口。例如,我想计算4月1日下午1点到4月7日下午1点钟之间的所有事件。

我想我可以计算每日窗口并保持结果的状态,但这似乎是最优的。

Flink是否支持在预先确定的开始和结束时间设置时间窗口?

似乎可以将其实现为批处理作业或有界流作业,只需将所有数据聚合在一起,而不是使用窗口,而是使用reduce或类似的方法。

相关内容

  • 没有找到相关文章

最新更新