org.apache.flink.streaming.api.operators

类 InternalTimeServiceManagerImpl<K>

java.lang.Object

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

类型参数:

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

所有已实现的接口:

InternalTimeServiceManager<K>

@Internal
public class InternalTimeServiceManagerImpl<K>
extends Object
implements InternalTimeServiceManager<K>

An entity keeping all the time-related services. Right now, this is only a timer services.

NOTE: These services are only available to keyed operators.

嵌套类概要

从接口继承的嵌套类/接口 org.apache.flink.streaming.api.operators.InternalTimeServiceManager

InternalTimeServiceManager.Provider, InternalTimeServiceManager.ShouldStopAdvancingFn

字段概要

字段

限定符和类型	字段和说明
protected static org.slf4j.Logger	LOG

方法概要

限定符和类型	方法和说明
void	advanceWatermark(Watermark watermark) Advances the Watermark of all managed timer services, potentially firing event time timers.
static <K> InternalTimeServiceManagerImpl<K>	create(org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup taskIOMetricGroup, org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> keyedStateBackend, ClassLoader userClassloader, KeyContext keyContext, ProcessingTimeService processingTimeService, Iterable<org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider> rawKeyedStates, StreamTaskCancellationContext cancellationContext) A factory method for creating the InternalTimeServiceManagerImpl.
<N> InternalTimerService<N>	getAsyncInternalTimerService(String name, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, Triggerable<K,N> triggerable, org.apache.flink.runtime.asyncprocessing.AsyncExecutionController<K> asyncExecutionController) Creates an InternalTimerServiceAsyncImpl for handling a group of timers identified by the given name.
<N> InternalTimerService<N>	getInternalTimerService(String name, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, Triggerable<K,N> triggerable) Creates an InternalTimerService for handling a group of timers identified by the given name.
int	numEventTimeTimers()
int	numProcessingTimeTimers()
void	snapshotToRawKeyedState(org.apache.flink.runtime.state.KeyedStateCheckpointOutputStream out, String operatorName) Snapshots the timers to raw keyed state.
boolean	tryAdvanceWatermark(Watermark watermark, InternalTimeServiceManager.ShouldStopAdvancingFn shouldStopAdvancingFn) Try to InternalTimeServiceManager.advanceWatermark(Watermark), but if InternalTimeServiceManager.ShouldStopAdvancingFn returns true, stop the advancement and return as soon as possible.

从类继承的方法 java.lang.Object

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

字段详细资料

LOG

protected static final org.slf4j.Logger LOG

方法详细资料

create

public static <K> InternalTimeServiceManagerImpl<K> create(org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup taskIOMetricGroup,
                                                           org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> keyedStateBackend,
                                                           ClassLoader userClassloader,
                                                           KeyContext keyContext,
                                                           ProcessingTimeService processingTimeService,
                                                           Iterable<org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider> rawKeyedStates,
                                                           StreamTaskCancellationContext cancellationContext)
                                                    throws Exception

A factory method for creating the InternalTimeServiceManagerImpl.

IMPORTANT: Keep in sync with InternalTimeServiceManager.Provider.

抛出:

Exception

getInternalTimerService

public <N> InternalTimerService<N> getInternalTimerService(String name,
                                                           org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer,
                                                           org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer,
                                                           Triggerable<K,N> triggerable)

从接口复制的说明: InternalTimeServiceManager

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.

指定者:

getInternalTimerService 在接口中 InternalTimeServiceManager<K>

getAsyncInternalTimerService

public <N> InternalTimerService<N> getAsyncInternalTimerService(String name,
                                                                org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer,
                                                                org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer,
                                                                Triggerable<K,N> triggerable,
                                                                org.apache.flink.runtime.asyncprocessing.AsyncExecutionController<K> asyncExecutionController)

从接口复制的说明: InternalTimeServiceManager

Creates an InternalTimerServiceAsyncImpl for handling a group of timers identified by the given name. The timers are scoped to a key and namespace. Mainly used by async operators.

Some essential order preservation will be added when the given Triggerable is invoked.

指定者:

getAsyncInternalTimerService 在接口中 InternalTimeServiceManager<K>

advanceWatermark

public void advanceWatermark(Watermark watermark)
                      throws Exception

从接口复制的说明: InternalTimeServiceManager

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

指定者:

advanceWatermark 在接口中 InternalTimeServiceManager<K>

抛出:

Exception

tryAdvanceWatermark

public boolean tryAdvanceWatermark(Watermark watermark,
                                   InternalTimeServiceManager.ShouldStopAdvancingFn shouldStopAdvancingFn)
                            throws Exception

从接口复制的说明: InternalTimeServiceManager

Try to InternalTimeServiceManager.advanceWatermark(Watermark), but if InternalTimeServiceManager.ShouldStopAdvancingFn returns true, stop the advancement and return as soon as possible.

指定者:

tryAdvanceWatermark 在接口中 InternalTimeServiceManager<K>

返回:

true if Watermark has been fully processed, false otherwise.

抛出:

Exception

snapshotToRawKeyedState

public void snapshotToRawKeyedState(org.apache.flink.runtime.state.KeyedStateCheckpointOutputStream out,
                                    String operatorName)
                             throws Exception

从接口复制的说明: InternalTimeServiceManager

Snapshots the timers to raw keyed state.

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

指定者:

snapshotToRawKeyedState 在接口中 InternalTimeServiceManager<K>

抛出:

Exception

numProcessingTimeTimers

@VisibleForTesting
public int numProcessingTimeTimers()

numEventTimeTimers

@VisibleForTesting
public int numEventTimeTimers()