Interface ProcessingTimeManager
-
- All Known Implementing Classes:
DefaultProcessingTimeManager
,UnsupportedProcessingTimeManager
@Experimental public interface ProcessingTimeManager
This is responsibility for managing runtime information related to processing time of process function.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description long
currentTime()
Get the current processing time.void
deleteTimer(long timestamp)
Deletes the processing-time timer with the given trigger timestamp.void
registerTimer(long timestamp)
Register a processing timer for this process function.
-
-
-
Method Detail
-
registerTimer
void registerTimer(long timestamp)
Register a processing timer for this process function. `onProcessingTimer` method of this function will be invoked as callback if the timer expires.- Parameters:
timestamp
- to trigger timer callback.
-
deleteTimer
void deleteTimer(long timestamp)
Deletes the processing-time timer with the given trigger timestamp. This method has only an effect if such a timer was previously registered and did not already expire.- Parameters:
timestamp
- indicates the timestamp of the timer to delete.
-
currentTime
long currentTime()
Get the current processing time.- Returns:
- current processing time.
-
-