org.apache.flink.streaming.api.operators

Class InternalTimeServiceManager<K>

java.lang.Object

org.apache.flink.streaming.api.operators.InternalTimeServiceManager<K>

Type Parameters:

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

@Internal
public class InternalTimeServiceManager<K>
extends Object

An entity keeping all the time-related services available to all operators extending the AbstractStreamOperator. Right now, this is only a timer services.

NOTE: These services are only available to keyed operators.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Method Summary

Modifier and Type	Method and Description
void	advanceWatermark(Watermark watermark)
<N> InternalTimerService<N>	getInternalTimerService(String name, TimerSerializer<K,N> timerSerializer, Triggerable<K,N> triggerable)
<N> InternalTimerService<N>	getInternalTimerService(String name, TypeSerializer<N> namespaceSerializer, Triggerable<K,N> triggerable, KeyedStateBackend<K> keyedStateBackend)
int	numEventTimeTimers()
int	numProcessingTimeTimers()
void	restoreStateForKeyGroup(InputStream stream, int keyGroupIdx, ClassLoader userCodeClassLoader)
void	snapshotState(KeyedStateBackend<?> keyedStateBackend, StateSnapshotContext context, String operatorName)
void	snapshotStateForKeyGroup(DataOutputView stream, int keyGroupIdx)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Method Detail

getInternalTimerService

public <N> InternalTimerService<N> getInternalTimerService(String name,
                                                           TypeSerializer<N> namespaceSerializer,
                                                           Triggerable<K,N> triggerable,
                                                           KeyedStateBackend<K> keyedStateBackend)

getInternalTimerService

public <N> InternalTimerService<N> getInternalTimerService(String name,
                                                           TimerSerializer<K,N> timerSerializer,
                                                           Triggerable<K,N> triggerable)

advanceWatermark

public void advanceWatermark(Watermark watermark)
                      throws Exception

Throws:

Exception

snapshotState

public void snapshotState(KeyedStateBackend<?> keyedStateBackend,
                          StateSnapshotContext context,
                          String operatorName)
                   throws Exception

Throws:

Exception

snapshotStateForKeyGroup

public void snapshotStateForKeyGroup(DataOutputView stream,
                                     int keyGroupIdx)
                              throws IOException

Throws:

IOException

restoreStateForKeyGroup

public void restoreStateForKeyGroup(InputStream stream,
                                    int keyGroupIdx,
                                    ClassLoader userCodeClassLoader)
                             throws IOException

Throws:

IOException

numProcessingTimeTimers

@VisibleForTesting
public int numProcessingTimeTimers()

numEventTimeTimers

@VisibleForTesting
public int numEventTimeTimers()