org.apache.flink.streaming.api.operators

Interface InternalTimeServiceManager<K>

Type Parameters:

K - The type of keys used for the timers and the registry.

All Known Implementing Classes:

BatchExecutionInternalTimeServiceManager, InternalTimeServiceManagerImpl

@Internal
public interface InternalTimeServiceManager<K>

An entity keeping all the time-related services.

NOTE: These services are only available to keyed operators.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	InternalTimeServiceManager.Provider A provider pattern for creating an instance of a InternalTimeServiceManager.

Method Summary

Modifier and Type	Method and Description
void	advanceWatermark(Watermark watermark) Advances the Watermark of all managed timer services, potentially firing event time timers.
<N> InternalTimerService<N>	getInternalTimerService(String name, TypeSerializer<K> keySerializer, TypeSerializer<N> namespaceSerializer, Triggerable<K,N> triggerable) Creates an InternalTimerService for handling a group of timers identified by the given name.
void	snapshotToRawKeyedState(KeyedStateCheckpointOutputStream stateCheckpointOutputStream, String operatorName) Snapshots the timers to raw keyed state.

Method Detail

getInternalTimerService

<N> InternalTimerService<N> getInternalTimerService(String name,
                                                    TypeSerializer<K> keySerializer,
                                                    TypeSerializer<N> namespaceSerializer,
                                                    Triggerable<K,N> triggerable)

Creates an InternalTimerService for handling a group of timers identified by the given name. The timers are scoped to a key and namespace.

When a timer fires the given Triggerable will be invoked.

advanceWatermark

void advanceWatermark(Watermark watermark)
               throws Exception

Advances the Watermark of all managed timer services, potentially firing event time timers.

Throws:

Exception

snapshotToRawKeyedState

void snapshotToRawKeyedState(KeyedStateCheckpointOutputStream stateCheckpointOutputStream,
                             String operatorName)
                      throws Exception

Snapshots the timers to raw keyed state.

TODO: This can be removed once heap-based timers are integrated with RocksDB incremental snapshots.

Throws:

Exception