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

Class LocalRecoveredInputChannel

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.LocalRecoveredInputChannel

public class LocalRecoveredInputChannel
extends RecoveredInputChannel

An input channel reads recovered state from previous unaligned checkpoint snapshots via ChannelStateReader and then converts into LocalInputChannel 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()

Specified by:

toInputChannel in class RecoveredInputChannel