我有一个用例，我想用预先确定的开始时间和结束时间来计算窗口。例如，我想计算4月1日下午1点到4月7日下午1点之间的所有事件。我想我可以计算每天的窗口，并保持结果的状态，但这似乎是最佳的。flink是否支持在预先确定的开始和结束时间设置时间窗口？
sg24os4d1#
似乎可以将其实现为批处理作业或有界流式处理作业，并简单地将所有数据聚合在一起，而不是使用窗口，而是使用reduce或类似的方法。
1条答案
按热度按时间sg24os4d1#
似乎可以将其实现为批处理作业或有界流式处理作业，并简单地将所有数据聚合在一起，而不是使用窗口，而是使用reduce或类似的方法。