flink中基于系统时间的事件触发器

Question

如何在 Flink 中设置触发器在特定时间过去后执行某些操作？ 例如：每天下午 1 点的流总和

Answer 1

A KeyedProcessFunction 可以使用计时器在特定时间触发操作（基于每个键）。这些可以是使用系统时间的处理时间计时器，也可以是由 Watermarks 触发的事件时间计时器。

以下是每个示例，来自文档中的教程：

• processing time timer

• event time timer

另见 the more detailed docs about process functions and timers。

请注意，如果您不想以键分区的方式应用计时器，而是需要对整个数据流进行操作（即非并行），您可以使用 keyBy(constant) 来获取将自己置于键控上下文中，而无需实际对流进行分区。