public class LocalRecoveredInputChannel extends RecoveredInputChannel
LocalInputChannel
finally.InputChannel.BufferAndAvailability
bufferManager, channelStateWriter, networkBuffersPerChannel
channelInfo, consumedSubpartitionIndex, initialBackoff, inputGate, maxBackoff, numBuffersIn, numBytesIn, partitionId
Modifier and Type | Method and Description |
---|---|
protected InputChannel |
toInputChannelInternal() |
acknowledgeAllRecordsProcessed, checkpointStarted, checkpointStopped, finishReadRecoveredState, getNextBuffer, getNumberOfQueuedBuffers, onRecoveredStateBuffer, requestBufferBlocking, resumeConsumption, setChannelStateWriter, toInputChannel
checkError, convertToPriorityEvent, getChannelIndex, getChannelInfo, getConsumedSubpartitionIndex, getCurrentBackoff, getPartitionId, increaseBackoff, notifyBufferAvailable, notifyChannelNonEmpty, notifyPriorityEvent, notifyRequiredSegmentId, setError, unsynchronizedGetNumberOfQueuedBuffers, unsynchronizedGetSizeOfQueuedBuffers
protected InputChannel toInputChannelInternal()
toInputChannelInternal
in class RecoveredInputChannel
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.