public abstract class RecoveredInputChannel extends InputChannel
ChannelStateReader
.InputChannel.BufferAndAvailability
Modifier and Type | Field and Description |
---|---|
protected BufferManager |
bufferManager |
channelInfo, initialBackoff, inputGate, maxBackoff, numBuffersIn, numBytesIn, partitionId
Modifier and Type | Method and Description |
---|---|
protected int |
getNumberOfQueuedBuffers() |
protected void |
readRecoveredState(ChannelStateReader reader) |
void |
resumeConsumption()
After sending a
CheckpointBarrier of
exactly-once mode, the upstream will be blocked and become unavailable. |
abstract InputChannel |
toInputChannel() |
checkError, getChannelIndex, getChannelInfo, getCurrentBackoff, getPartitionId, increaseBackoff, notifyBufferAvailable, notifyChannelNonEmpty, parseCheckpointBarrierOrNull, setError, spillInflightBuffers, unsynchronizedGetNumberOfQueuedBuffers
protected final BufferManager bufferManager
public abstract InputChannel toInputChannel() throws IOException
IOException
protected void readRecoveredState(ChannelStateReader reader) throws IOException, InterruptedException
IOException
InterruptedException
public void resumeConsumption()
InputChannel
CheckpointBarrier
of
exactly-once mode, the upstream will be blocked and become unavailable. This method tries to
unblock the corresponding upstream and resume data consumption.resumeConsumption
in class InputChannel
@VisibleForTesting protected int getNumberOfQueuedBuffers()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.