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