org.apache.flink.streaming.api.operators.sorted.state

类 BatchExecutionInternalTimeServiceManager<K>

java.lang.Object

org.apache.flink.streaming.api.operators.sorted.state.BatchExecutionInternalTimeServiceManager<K>

所有已实现的接口:

org.apache.flink.runtime.state.KeyedStateBackend.KeySelectionListener<K>, InternalTimeServiceManager<K>

public class BatchExecutionInternalTimeServiceManager<K>
extends Object
implements InternalTimeServiceManager<K>, org.apache.flink.runtime.state.KeyedStateBackend.KeySelectionListener<K>

An implementation of a InternalTimeServiceManager that manages timers with a single active key at a time. Can be used in a BATCH execution mode.

嵌套类概要

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

InternalTimeServiceManager.Provider, InternalTimeServiceManager.ShouldStopAdvancingFn

构造器概要

构造器

构造器和说明
BatchExecutionInternalTimeServiceManager(ProcessingTimeService processingTimeService)

方法概要

限定符和类型	方法和说明
void	advanceWatermark(Watermark watermark) Advances the Watermark of all managed timer services, potentially firing event time timers.
static <K> InternalTimeServiceManager<K>	create(org.apache.flink.runtime.metrics.groups.TaskIOMetricGroup taskIOMetricGroup, org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> keyedStatedBackend, ClassLoader userClassloader, KeyContext keyContext, ProcessingTimeService processingTimeService, Iterable<org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider> rawKeyedStates, StreamTaskCancellationContext cancellationContext)
<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.
void	keySelected(K newKey)
void	snapshotToRawKeyedState(org.apache.flink.runtime.state.KeyedStateCheckpointOutputStream context, 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

构造器详细资料

BatchExecutionInternalTimeServiceManager

public BatchExecutionInternalTimeServiceManager(ProcessingTimeService processingTimeService)

方法详细资料

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)

从接口复制的说明: InternalTimeServiceManager

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

指定者:

advanceWatermark 在接口中 InternalTimeServiceManager<K>

tryAdvanceWatermark

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

从接口复制的说明: 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.

snapshotToRawKeyedState

public void snapshotToRawKeyedState(org.apache.flink.runtime.state.KeyedStateCheckpointOutputStream context,
                                    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

create

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

keySelected

public void keySelected(K newKey)

指定者:

keySelected 在接口中 org.apache.flink.runtime.state.KeyedStateBackend.KeySelectionListener<K>