org.apache.flink.streaming.api.operators

类 InternalTimerServiceAsyncImpl<K,N>

java.lang.Object

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

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

类型参数:

K - Type of timer's key.

N - Type of the namespace to which timers are scoped.

所有已实现的接口:

InternalTimerService<N>

@Internal
public class InternalTimerServiceAsyncImpl<K,N>
extends InternalTimerServiceImpl<K,N>

An implementation of InternalTimerService that is used by AbstractAsyncStateStreamOperator. The timer service will set RecordContext for the timers before invoking action to preserve the execution order between timer firing and records processing.

另请参阅:

FLIP-425 timers section.

字段概要

从类继承的字段 org.apache.flink.streaming.api.operators.InternalTimerServiceImpl

cancellationContext, currentWatermark, eventTimeTimersQueue, keyContext, nextTimer, processingTimeService, processingTimeTimersQueue, taskIOMetricGroup, triggerTarget

方法概要

限定符和类型	方法和说明
void	advanceWatermark(long time) Advance one watermark, this will fire some event timers.
protected void	foreachTimer(org.apache.flink.util.function.BiConsumerWithException<N,Long,Exception> consumer, org.apache.flink.runtime.state.KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K,N>> queue) Iterator each timer in the queue, and invoke the consumer.

从类继承的方法 org.apache.flink.streaming.api.operators.InternalTimerServiceImpl

currentProcessingTime, currentWatermark, deleteEventTimeTimer, deleteProcessingTimeTimer, forEachEventTimeTimer, forEachProcessingTimeTimer, getKeySerializer, getNamespaceSerializer, numEventTimeTimers, numEventTimeTimers, numProcessingTimeTimers, numProcessingTimeTimers, registerEventTimeTimer, registerProcessingTimeTimer, restoreTimersForKeyGroup, snapshotTimersForKeyGroup, startTimerService, tryAdvanceWatermark

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

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

方法详细资料

advanceWatermark

public void advanceWatermark(long time)
                      throws Exception

Advance one watermark, this will fire some event timers.

覆盖:

advanceWatermark 在类中 InternalTimerServiceImpl<K,N>

参数:

time - the time in watermark.

抛出:

Exception

foreachTimer

protected void foreachTimer(org.apache.flink.util.function.BiConsumerWithException<N,Long,Exception> consumer,
                            org.apache.flink.runtime.state.KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K,N>> queue)
                     throws Exception

Iterator each timer in the queue, and invoke the consumer. This function is mainly used by state-processor-API. TODO: Ensure state-processor-API that only uses sync state API.

覆盖:

foreachTimer 在类中 InternalTimerServiceImpl<K,N>

抛出:

Exception