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