Interface ClockService
-
@Internal public interface ClockServiceA clock service which can get current processing time. This can help to mock processing time in tests.
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description longcurrentProcessingTime()Returns the current processing time.static ClockServiceof(org.apache.flink.streaming.api.operators.InternalTimerService<?> timerService)Creates aClockServicefrom the givenInternalTimerService.static ClockServiceofSystem()Creates aClockServicewhich assigns as current processing time the result of callingSystem.currentTimeMillis().
-
-
-
Method Detail
-
currentProcessingTime
long currentProcessingTime()
Returns the current processing time.
-
of
static ClockService of(org.apache.flink.streaming.api.operators.InternalTimerService<?> timerService)
Creates aClockServicefrom the givenInternalTimerService.
-
ofSystem
static ClockService ofSystem()
Creates aClockServicewhich assigns as current processing time the result of callingSystem.currentTimeMillis().
-
-