flink窗口，何时启动

eqoofvh9 于 2021-06-25 发布在 Flink

关注(0)|答案(1)|浏览(409)

我想从apache flink数据流中捕捉每一个“自然”小时的事件。也就是说，我想在一个窗口中捕捉从12:00:00到12:59:59，13:00:00到13:59:59的事件。。。
我一直在使用：

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

但是我怎么知道这60分钟是从每一个点开始的，比如说，从12:30到13:29:59，窗口不是吗？

1条答案

你的答案在这里。总结一下：
对于翻滚窗和滑动窗，窗与epoch对齐（1970年1月1日00:00:00）。因此，如果不更改offset参数，则翻滚窗口将与“0点钟”时间匹配。