N
- Type of the namespace to which timers are scoped.@Internal public interface InternalTimerService<N>
This is the internal version of TimerService
that allows to specify a key and a namespace to which timers should be scoped.
Modifier and Type | Method and Description |
---|---|
long |
currentProcessingTime()
Returns the current processing time.
|
long |
currentWatermark()
Returns the current event-time watermark.
|
void |
deleteEventTimeTimer(N namespace,
long time)
Deletes the timer for the given key and namespace.
|
void |
deleteProcessingTimeTimer(N namespace,
long time)
Deletes the timer for the given key and namespace.
|
void |
registerEventTimeTimer(N namespace,
long time)
Registers a timer to be fired when processing time passes the given time.
|
void |
registerProcessingTimeTimer(N namespace,
long time)
Registers a timer to be fired when processing time passes the given time.
|
long currentProcessingTime()
long currentWatermark()
void registerProcessingTimeTimer(N namespace, long time)
void deleteProcessingTimeTimer(N namespace, long time)
void registerEventTimeTimer(N namespace, long time)
void deleteEventTimeTimer(N namespace, long time)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.