@Internal public final class StreamTaskNetworkInput<T> extends AbstractStreamTaskNetworkInput<T,SpillingAdaptiveSpanningRecordDeserializer<DeserializationDelegate<StreamElement>>>
StreamTaskInputthat wraps an input from network taken from
This internally uses a
StatusWatermarkValve to keep track of
StreamStatus events, and forwards them to event subscribers once the
StatusWatermarkValve determines the
Watermark from all inputs has advanced, or that a
StreamStatus needs to be propagated downstream to denote a status change.
Forwarding elements, watermarks, or status elements must be protected by synchronizing on the
given lock object. This ensures that we don't call methods on a
concurrently with the timer callback or other things.
checkpointedInputGate, deserializationDelegate, flattenedChannelIndices, inputIndex, inputSerializer, recordDeserializers, statusWatermarkValve
|Constructor and Description|
|Modifier and Type||Method and Description|
Prepares to spill the in-flight input buffers as checkpoint snapshot.
emitNext, getActiveSerializer, getAvailableFuture, getInputIndex, processBuffer, processEvent, releaseDeserializer
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public CompletableFuture<Void> prepareSnapshot(ChannelStateWriter channelStateWriter, long checkpointId) throws CheckpointException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.