org.apache.flink.runtime.io.network.partition.consumer

Class RemoteRecoveredInputChannel

java.lang.Object

org.apache.flink.runtime.io.network.partition.consumer.InputChannel

org.apache.flink.runtime.io.network.partition.consumer.RecoveredInputChannel

org.apache.flink.runtime.io.network.partition.consumer.RemoteRecoveredInputChannel

public class RemoteRecoveredInputChannel
extends RecoveredInputChannel

An input channel reads recovered state from previous unaligned checkpoint snapshots via ChannelStateReader and then converts into RemoteInputChannel finally.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.runtime.io.network.partition.consumer.InputChannel

InputChannel.BufferAndAvailability

Field Summary

Fields inherited from class org.apache.flink.runtime.io.network.partition.consumer.RecoveredInputChannel

bufferManager

Fields inherited from class org.apache.flink.runtime.io.network.partition.consumer.InputChannel

channelInfo, initialBackoff, inputGate, maxBackoff, numBuffersIn, numBytesIn, partitionId

Method Summary

Modifier and Type	Method and Description
InputChannel	toInputChannel()

Methods inherited from class org.apache.flink.runtime.io.network.partition.consumer.RecoveredInputChannel

getNumberOfQueuedBuffers, readRecoveredState, resumeConsumption

Methods inherited from class org.apache.flink.runtime.io.network.partition.consumer.InputChannel

checkError, getChannelIndex, getChannelInfo, getCurrentBackoff, getPartitionId, increaseBackoff, notifyBufferAvailable, notifyChannelNonEmpty, parseCheckpointBarrierOrNull, setError, spillInflightBuffers, unsynchronizedGetNumberOfQueuedBuffers

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

toInputChannel

public InputChannel toInputChannel()
                            throws IOException

Specified by:

toInputChannel in class RecoveredInputChannel

Throws:

IOException