@PublicEvolving public interface TimerService
Modifier and Type | Method and Description |
---|---|
long |
currentProcessingTime()
Returns the current processing time.
|
long |
currentWatermark()
Returns the current event-time watermark.
|
void |
registerEventTimeTimer(long time)
Registers a timer to be fired when the event time watermark passes the given time.
|
void |
registerProcessingTimeTimer(long time)
Registers a timer to be fired when processing time passes the given time.
|
long currentProcessingTime()
long currentWatermark()
void registerProcessingTimeTimer(long 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 also be active when you receive the timer notification.
void registerEventTimeTimer(long 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 also be active when you receive the timer notification.
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.