Timer#

TimerService#

TimerService.current_processing_time()

Returns the current processing time.

TimerService.current_watermark()

Returns the current event-time watermark.

TimerService.register_processing_time_timer(...)

Registers a timer to be fired when processing time passes the given time.

TimerService.register_event_time_timer(timestamp)

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

TimerService.delete_processing_time_timer(...)

Deletes the processing-time timer with the given trigger time.

TimerService.delete_event_time_timer(timestamp)

Deletes the event-time timer with the given trigger time.

TimeDomain#

TimeDomain(value)

TimeDomain specifies whether a firing timer is based on event time or processing time.