pyflink.datastream.timerservice.TimerService.register_processing_time_timer

abstract TimerService.register_processing_time_timer(timestamp: int)

Registers a timer to be fired when processing time 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 processing time of the timer to be registered.