org.apache.flink.streaming.api

Class SimpleTimerService

java.lang.Object

org.apache.flink.streaming.api.SimpleTimerService

All Implemented Interfaces:

TimerService

@Internal
public class SimpleTimerService
extends Object
implements TimerService

Implementation of TimerService that uses a InternalTimerService.

Constructor Summary

Constructors

Constructor and Description
SimpleTimerService(InternalTimerService<VoidNamespace> internalTimerService)

Method Summary

Modifier and Type	Method and Description
long	currentProcessingTime() Returns the current processing time.
long	currentWatermark() Returns the current event-time watermark.
void	registerEventTimeTimer(long time) Registers a timer to be fired when the event time watermark passes the given time.
void	registerProcessingTimeTimer(long time) Registers a timer to be fired when processing time passes the given time.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleTimerService

public SimpleTimerService(InternalTimerService<VoidNamespace> internalTimerService)

Method Detail

currentProcessingTime

public long currentProcessingTime()

Description copied from interface: TimerService

Returns the current processing time.

Specified by:

currentProcessingTime in interface TimerService

currentWatermark

public long currentWatermark()

Description copied from interface: TimerService

Returns the current event-time watermark.

Specified by:

currentWatermark in interface TimerService

registerProcessingTimeTimer

public void registerProcessingTimeTimer(long time)

Description copied from interface: TimerService

Registers a timer to be fired when processing time passes the given time.

Timers can internally be scoped to keys and/or windows. When you set a timer in a keyed context, such as in an operation on KeyedStream then that context will also be active when you receive the timer notification.

Specified by:

registerProcessingTimeTimer in interface TimerService

registerEventTimeTimer

public void registerEventTimeTimer(long time)

Description copied from interface: TimerService

Registers a timer to be fired when the event time watermark passes the given time.

Timers can internally be scoped to keys and/or windows. When you set a timer in a keyed context, such as in an operation on KeyedStream then that context will also be active when you receive the timer notification.

Specified by:

registerEventTimeTimer in interface TimerService