Class SlicingWindowTimerServiceImpl

    • Constructor Detail

      • SlicingWindowTimerServiceImpl

        public SlicingWindowTimerServiceImpl​(org.apache.flink.streaming.api.operators.InternalTimerService<Long> internalTimerService,
                                             java.time.ZoneId shiftTimeZone)
    • Method Detail

      • registerProcessingTimeWindowTimer

        public void registerProcessingTimeWindowTimer​(Long window)
        Description copied from interface: WindowTimerService
        Registers a window timer to be fired when processing time passes the window. The window you pass here will be provided when the timer fires.
      • registerEventTimeWindowTimer

        public void registerEventTimeWindowTimer​(Long window)
        Description copied from interface: WindowTimerService
        Registers a window timer to be fired when event time watermark passes the window. The window you pass here will be provided when the timer fires.