Class UnslicingWindowTimerServiceImpl

    • Constructor Detail

      • UnslicingWindowTimerServiceImpl

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

      • registerProcessingTimeWindowTimer

        public void registerProcessingTimeWindowTimer​(TimeWindow 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​(TimeWindow 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.