Interface ClockService


  • @Internal
    public interface ClockService
    A clock service which can get current processing time. This can help to mock processing time in tests.
    • Method Detail

      • currentProcessingTime

        long currentProcessingTime()
        Returns the current processing time.
      • of

        static ClockService of​(org.apache.flink.streaming.api.operators.InternalTimerService<?> timerService)
        Creates a ClockService from the given InternalTimerService.