flink Windows，它们什么时候启动

Question

我想在每个“自然”小时从 Apache Flink DataStream 捕获事件。也就是说，我想在 12:00:00 到 12:59:59、13:00:00 到 13:59:59 的窗口中捕获事件...

我一直在使用：

datastream.keyBy(0)
.timeWindow(Time.minutes(60))

但是我怎么知道这 60 分钟从每点开始，并且窗口不是从 12:30:00 到 13:29:59？

Answer 1

您的答案是here。总结一下：

对于翻滚和滑动窗口，窗口与纪元（1970 年 1 月 1 日 00:00:00）对齐。因此，如果您不更改 offset 参数，那么您的滚动窗口将匹配“o'clock”时间。