Class 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 Detail

      • currentProcessingTime

        public long currentProcessingTime()
        Specified by:
        currentProcessingTime in interface org.apache.flink.streaming.api.TimerService
      • currentWatermark

        public long currentWatermark()
        Specified by:
        currentWatermark in interface org.apache.flink.streaming.api.TimerService
      • registerProcessingTimeTimer

        public void registerProcessingTimeTimer​(long time)
        Specified by:
        registerProcessingTimeTimer in interface org.apache.flink.streaming.api.TimerService
      • registerEventTimeTimer

        public void registerEventTimeTimer​(long time)
        Specified by:
        registerEventTimeTimer in interface org.apache.flink.streaming.api.TimerService
      • deleteProcessingTimeTimer

        public void deleteProcessingTimeTimer​(long time)
        Specified by:
        deleteProcessingTimeTimer in interface org.apache.flink.streaming.api.TimerService
      • deleteEventTimeTimer

        public void deleteEventTimeTimer​(long time)
        Specified by:
        deleteEventTimeTimer in interface org.apache.flink.streaming.api.TimerService