Apache Flink 在特定的开始和结束时间开窗
Apache Flink Windowing At Specific Start and End Times
我有一个用例，我想用预先确定的开始时间和结束时间来计算 windows。例如，我想计算 4 月 1 日下午 1 点到 4 月 7 日下午 1 点之间的所有事件。
我想我可以每天计算 windows 并将结果保持在状态，但这似乎是最佳选择。
Flink 是否支持在预先确定的开始和结束时间设置时间窗口？
似乎您可以将其实现为批处理作业或有界流作业，并简单地将所有数据聚合在一起，而不是使用 window，而是使用 reduce 或类似的东西。
我有一个用例，我想用预先确定的开始时间和结束时间来计算 windows。例如，我想计算 4 月 1 日下午 1 点到 4 月 7 日下午 1 点之间的所有事件。
我想我可以每天计算 windows 并将结果保持在状态，但这似乎是最佳选择。
Flink 是否支持在预先确定的开始和结束时间设置时间窗口？
似乎您可以将其实现为批处理作业或有界流作业，并简单地将所有数据聚合在一起，而不是使用 window，而是使用 reduce 或类似的东西。