org.apache.flink.streaming.api.operators

Class InternalTimerServiceImpl<K,N>

java.lang.Object

org.apache.flink.streaming.api.operators.InternalTimerServiceImpl<K,N>

All Implemented Interfaces:

InternalTimerService<N>

public class InternalTimerServiceImpl<K,N>
extends Object
implements InternalTimerService<N>

InternalTimerService that stores timers on the Java heap.

Method Summary

Modifier and Type	Method and Description
void	advanceWatermark(long time)
long	currentProcessingTime() Returns the current processing time.
long	currentWatermark() Returns the current event-time watermark.
void	deleteEventTimeTimer(N namespace, long time) Deletes the timer for the given key and namespace.
void	deleteProcessingTimeTimer(N namespace, long time) Deletes the timer for the given key and namespace.
void	forEachEventTimeTimer(BiConsumerWithException<N,Long,Exception> consumer) Performs an action for each registered timer.
void	forEachProcessingTimeTimer(BiConsumerWithException<N,Long,Exception> consumer) Performs an action for each registered timer.
TypeSerializer<K>	getKeySerializer()
TypeSerializer<N>	getNamespaceSerializer()
int	numEventTimeTimers()
int	numEventTimeTimers(N namespace)
int	numProcessingTimeTimers()
int	numProcessingTimeTimers(N namespace)
void	registerEventTimeTimer(N namespace, long time) Registers a timer to be fired when event time watermark passes the given time.
void	registerProcessingTimeTimer(N namespace, long time) Registers a timer to be fired when processing time passes the given time.
void	restoreTimersForKeyGroup(InternalTimersSnapshot<?,?> restoredSnapshot, int keyGroupIdx) Restore the timers (both processing and event time ones) for a given keyGroupIdx.
InternalTimersSnapshot<K,N>	snapshotTimersForKeyGroup(int keyGroupIdx) Snapshots the timers (both processing and event time ones) for a given keyGroupIdx.
void	startTimerService(TypeSerializer<K> keySerializer, TypeSerializer<N> namespaceSerializer, Triggerable<K,N> triggerTarget) Starts the local InternalTimerServiceImpl by: Setting the keySerialized and namespaceSerializer for the timers it will contain.

Methods inherited from class java.lang.Object

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

Method Detail

startTimerService

public void startTimerService(TypeSerializer<K> keySerializer,
                              TypeSerializer<N> namespaceSerializer,
                              Triggerable<K,N> triggerTarget)

Starts the local InternalTimerServiceImpl by:

1. Setting the keySerialized and namespaceSerializer for the timers it will contain.
2. Setting the triggerTarget which contains the action to be performed when a timer fires.
3. Re-registering timers that were retrieved after recovering from a node failure, if any.

This method can be called multiple times, as long as it is called with the same serializers.

currentProcessingTime

public long currentProcessingTime()

Description copied from interface: InternalTimerService

Returns the current processing time.

Specified by:

currentProcessingTime in interface InternalTimerService<N>

currentWatermark

public long currentWatermark()

Description copied from interface: InternalTimerService

Returns the current event-time watermark.

Specified by:

currentWatermark in interface InternalTimerService<N>

registerProcessingTimeTimer

public void registerProcessingTimeTimer(N namespace,
                                        long time)

Description copied from interface: InternalTimerService

Registers a timer to be fired when processing time passes the given time. The namespace you pass here will be provided when the timer fires.

Specified by:

registerProcessingTimeTimer in interface InternalTimerService<N>

registerEventTimeTimer

public void registerEventTimeTimer(N namespace,
                                   long time)

Description copied from interface: InternalTimerService

Registers a timer to be fired when event time watermark passes the given time. The namespace you pass here will be provided when the timer fires.

Specified by:

registerEventTimeTimer in interface InternalTimerService<N>

deleteProcessingTimeTimer

public void deleteProcessingTimeTimer(N namespace,
                                      long time)

Description copied from interface: InternalTimerService

Deletes the timer for the given key and namespace.

Specified by:

deleteProcessingTimeTimer in interface InternalTimerService<N>

deleteEventTimeTimer

public void deleteEventTimeTimer(N namespace,
                                 long time)

Description copied from interface: InternalTimerService

Deletes the timer for the given key and namespace.

Specified by:

deleteEventTimeTimer in interface InternalTimerService<N>

forEachEventTimeTimer

public void forEachEventTimeTimer(BiConsumerWithException<N,Long,Exception> consumer)
                           throws Exception

Description copied from interface: InternalTimerService

Performs an action for each registered timer. The timer service will set the key context for the timers key before invoking the action.

Specified by:

forEachEventTimeTimer in interface InternalTimerService<N>

Throws:

Exception

forEachProcessingTimeTimer

public void forEachProcessingTimeTimer(BiConsumerWithException<N,Long,Exception> consumer)
                                throws Exception

Description copied from interface: InternalTimerService

Performs an action for each registered timer. The timer service will set the key context for the timers key before invoking the action.

Specified by:

forEachProcessingTimeTimer in interface InternalTimerService<N>

Throws:

Exception

advanceWatermark

public void advanceWatermark(long time)
                      throws Exception

Throws:

Exception

snapshotTimersForKeyGroup

public InternalTimersSnapshot<K,N> snapshotTimersForKeyGroup(int keyGroupIdx)

Snapshots the timers (both processing and event time ones) for a given keyGroupIdx.

Parameters:

keyGroupIdx - the id of the key-group to be put in the snapshot.

Returns:

a snapshot containing the timers for the given key-group, and the serializers for them

getKeySerializer

public TypeSerializer<K> getKeySerializer()

getNamespaceSerializer

public TypeSerializer<N> getNamespaceSerializer()

restoreTimersForKeyGroup

public void restoreTimersForKeyGroup(InternalTimersSnapshot<?,?> restoredSnapshot,
                                     int keyGroupIdx)

Restore the timers (both processing and event time ones) for a given keyGroupIdx.

Parameters:

restoredSnapshot - the restored snapshot containing the key-group's timers, and the serializers that were used to write them

keyGroupIdx - the id of the key-group to be put in the snapshot.

numProcessingTimeTimers

@VisibleForTesting
public int numProcessingTimeTimers()

numEventTimeTimers

@VisibleForTesting
public int numEventTimeTimers()

numProcessingTimeTimers

@VisibleForTesting
public int numProcessingTimeTimers(N namespace)

numEventTimeTimers

@VisibleForTesting
public int numEventTimeTimers(N namespace)