在flink、Java中在Event上启动定时器并在定时器之后触发另一个事件

Question

我想知道Flink中是否有定时器以及在这种情况下我将如何实现它。目前我正在接收来自车辆的包含地理位置、速度等的数据。对于每个数据项，我都会处理并创建事件，例如超速事件、地理位置进入和退出等。我想要做的处理之一是在创建地理围栏输入事件后启动计时器，然后在经过设定的时间后立即触发一个函数来创建另一个事件。这是必需的，因为车辆可能进入地理围栏，但我当时没有获得另一个数据项，然后我想创建一个 EXCESS_STOP 事件。 Flink 中是否可以有一个计时器并在计时器末端触发一个事件，而无需在我的 Kafka 源上接收到另一个数据项。如果是这样，它是什么？在哪里我可以获取有关如何实现它的信息。

Answer 1

定时器可通过 KeyedProcessFunction 使用。您可以在docs中找到更多信息。