K
- Type of timer's key.N
- Type of the namespace to which timers are scoped.@Internal public class InternalTimerServiceAsyncImpl<K,N> extends InternalTimerServiceImpl<K,N>
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.cancellationContext, currentWatermark, eventTimeTimersQueue, keyContext, nextTimer, processingTimeService, processingTimeTimersQueue, taskIOMetricGroup, triggerTarget
Modifier and Type | Method and Description |
---|---|
void |
advanceWatermark(long time)
Advance one watermark, this will fire some event timers.
|
protected void |
foreachTimer(BiConsumerWithException<N,Long,Exception> consumer,
KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K,N>> queue)
Iterator each timer in the queue, and invoke the consumer.
|
currentProcessingTime, currentWatermark, deleteEventTimeTimer, deleteProcessingTimeTimer, forEachEventTimeTimer, forEachProcessingTimeTimer, getKeySerializer, getNamespaceSerializer, numEventTimeTimers, numEventTimeTimers, numProcessingTimeTimers, numProcessingTimeTimers, registerEventTimeTimer, registerProcessingTimeTimer, restoreTimersForKeyGroup, snapshotTimersForKeyGroup, startTimerService
public void advanceWatermark(long time) throws Exception
advanceWatermark
in class InternalTimerServiceImpl<K,N>
time
- the time in watermark.Exception
protected void foreachTimer(BiConsumerWithException<N,Long,Exception> consumer, KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K,N>> queue) throws Exception
foreachTimer
in class InternalTimerServiceImpl<K,N>
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.