Class LazyTimerService
- java.lang.Object
-
- org.apache.flink.state.api.output.operators.LazyTimerService
-
- All Implemented Interfaces:
org.apache.flink.streaming.api.TimerService
@Internal public class LazyTimerService extends Object implements org.apache.flink.streaming.api.TimerService
A timer service that initializes its internal timer service lazily.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longcurrentProcessingTime()longcurrentWatermark()voiddeleteEventTimeTimer(long time)voiddeleteProcessingTimeTimer(long time)voidregisterEventTimeTimer(long time)voidregisterProcessingTimeTimer(long time)
-
-
-
Method Detail
-
currentProcessingTime
public long currentProcessingTime()
- Specified by:
currentProcessingTimein interfaceorg.apache.flink.streaming.api.TimerService
-
currentWatermark
public long currentWatermark()
- Specified by:
currentWatermarkin interfaceorg.apache.flink.streaming.api.TimerService
-
registerProcessingTimeTimer
public void registerProcessingTimeTimer(long time)
- Specified by:
registerProcessingTimeTimerin interfaceorg.apache.flink.streaming.api.TimerService
-
registerEventTimeTimer
public void registerEventTimeTimer(long time)
- Specified by:
registerEventTimeTimerin interfaceorg.apache.flink.streaming.api.TimerService
-
deleteProcessingTimeTimer
public void deleteProcessingTimeTimer(long time)
- Specified by:
deleteProcessingTimeTimerin interfaceorg.apache.flink.streaming.api.TimerService
-
deleteEventTimeTimer
public void deleteEventTimeTimer(long time)
- Specified by:
deleteEventTimeTimerin interfaceorg.apache.flink.streaming.api.TimerService
-
-