flink翻滚窗口触发时间

kg7wmglp 于 2021-06-04 发布在 Kafka

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

我用flink收集Kafka主题的数据。我使用的是1小时的翻滚窗口，时间特性设置为事件时间。我还使用ascendingtimestampextractor，并基于json中的特定字段值为输入指定水印。 env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime); 我们可以假设用于水印的json字段具有类似于系统时钟的时间值。
如果我在下午3:25部署作业，我什么时候可以期望flink聚合输出？会在下午4点，5点。。。或下午3:25-4:25，下午4:25-下午5:25。。。。

Java apache-kafka apache-flink windowing Stream

来源：https://stackoverflow.com/questions/60634265/flink-tumble-window-trigger-time

1条答案

按热度按时间

eivnm1vs1#

flink的窗口与epoch（而不是第一个事件）对齐，因此如果在3:25部署作业，则第一个窗口的时间间隔约为3:00:00到3:59:59.999，并且很快就会生成（基于水印）。
请注意，您可以向构造函数传递偏移量，因此如果希望窗口在一小时后10分钟结束，可以通过指定

.window(TumblingEventTimeWindows.of(Time.hours(1), Time.minutes(10)))

赞(0）回复(0）举报 2021-06-04

我来回答

flink翻滚窗口触发时间

1条答案

相关问题

热门标签

最新问答