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.