pyflink.datastream.timerservice.TimerService.register_event_time_timer

abstract TimerService.register_event_time_timer(timestamp: int)

Registers a timer tobe fired when the event time watermark passes the given time.

Timers can internally be scoped to keys and/or windows. When you set a timer in a keyed context, such as in an operation on KeyedStream then that context will so be active when you receive the timer notification.

Parameters

timestamp – The event time of the timer to be registered.