Package org.apache.flink.api.common.operators

Interface ProcessingTimeService

@PublicEvolving
public interface ProcessingTimeService

A service that allows to get the current processing time and register timers that will execute the given ProcessingTimeService.ProcessingTimeCallback when firing.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	ProcessingTimeService.ProcessingTimeCallback	A callback that can be registered via registerTimer(long, ProcessingTimeCallback).

Method Summary

Modifier and Type	Method	Description
long	getCurrentProcessingTime()	Returns the current processing time.
ScheduledFuture<?>	registerTimer(long timestamp, ProcessingTimeService.ProcessingTimeCallback target)	Registers a task to be executed when (processing) time is timestamp.

Method Detail

getCurrentProcessingTime

long getCurrentProcessingTime()

Returns the current processing time.

registerTimer

ScheduledFuture<?> registerTimer(long timestamp,
                                 ProcessingTimeService.ProcessingTimeCallback target)

Registers a task to be executed when (processing) time is timestamp.

Parameters:

timestamp - Time when the task is to be executed (in processing time)

target - The task to be executed

Returns:

The future that represents the scheduled task. This always returns some future, even if the timer was shut down