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