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

Class RecoveredInputChannel

java.lang.Object

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

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

All Implemented Interfaces:

ChannelStateHolder

Direct Known Subclasses:

LocalRecoveredInputChannel, RemoteRecoveredInputChannel

public abstract class RecoveredInputChannel
extends InputChannel
implements ChannelStateHolder

An input channel reads recovered state from previous unaligned checkpoint snapshots.

Nested Class Summary

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

InputChannel.BufferAndAvailability

Field Summary

Fields

Modifier and Type	Field and Description
protected BufferManager	bufferManager
protected ChannelStateWriter	channelStateWriter
protected int	networkBuffersPerChannel

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

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

Method Summary

Modifier and Type	Method and Description
void	acknowledgeAllRecordsProcessed() When received EndOfData from one channel, it need to acknowledge after this event get processed.
void	checkpointStarted(CheckpointBarrier barrier) Called by task thread when checkpointing is started (e.g., any input channel received barrier).
void	checkpointStopped(long checkpointId) Called by task thread on cancel/complete to clean-up temporary data.
void	finishReadRecoveredState()
Optional<InputChannel.BufferAndAvailability>	getNextBuffer() Returns the next buffer from the consumed subpartition or Optional.empty() if there is no data to return.
protected int	getNumberOfQueuedBuffers()
void	onRecoveredStateBuffer(Buffer buffer)
Buffer	requestBufferBlocking()
void	resumeConsumption() After sending a CheckpointBarrier of exactly-once mode, the upstream will be blocked and become unavailable.
void	setChannelStateWriter(ChannelStateWriter channelStateWriter) Injects the ChannelStateWriter.
InputChannel	toInputChannel()
protected abstract InputChannel	toInputChannelInternal()

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

checkError, convertToPriorityEvent, getChannelIndex, getChannelInfo, getConsumedSubpartitionIndex, getCurrentBackoff, getPartitionId, increaseBackoff, notifyBufferAvailable, notifyChannelNonEmpty, notifyPriorityEvent, notifyRequiredSegmentId, setError, unsynchronizedGetNumberOfQueuedBuffers, unsynchronizedGetSizeOfQueuedBuffers

Methods inherited from class java.lang.Object

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

Field Detail

bufferManager

protected final BufferManager bufferManager

channelStateWriter

protected ChannelStateWriter channelStateWriter

networkBuffersPerChannel

protected final int networkBuffersPerChannel

Method Detail

setChannelStateWriter

public void setChannelStateWriter(ChannelStateWriter channelStateWriter)

Description copied from interface: ChannelStateHolder

Injects the ChannelStateWriter. Must only be called once.

Specified by:

setChannelStateWriter in interface ChannelStateHolder

toInputChannel

public final InputChannel toInputChannel()
                                  throws IOException

Throws:

IOException

checkpointStopped

public void checkpointStopped(long checkpointId)

Description copied from class: InputChannel

Called by task thread on cancel/complete to clean-up temporary data.

Overrides:

checkpointStopped in class InputChannel

toInputChannelInternal

protected abstract InputChannel toInputChannelInternal()
                                                throws IOException

Throws:

IOException

onRecoveredStateBuffer

public void onRecoveredStateBuffer(Buffer buffer)

finishReadRecoveredState

public void finishReadRecoveredState()
                              throws IOException

Throws:

IOException

getNextBuffer

public Optional<InputChannel.BufferAndAvailability> getNextBuffer()
                                                           throws IOException

Description copied from class: InputChannel

Returns the next buffer from the consumed subpartition or Optional.empty() if there is no data to return.

Specified by:

getNextBuffer in class InputChannel

Throws:

IOException

resumeConsumption

public void resumeConsumption()

Description copied from class: InputChannel

After sending a 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.

Specified by:

resumeConsumption in class InputChannel

acknowledgeAllRecordsProcessed

public void acknowledgeAllRecordsProcessed()
                                    throws IOException

Description copied from class: InputChannel

When received EndOfData from one channel, it need to acknowledge after this event get processed.

Specified by:

acknowledgeAllRecordsProcessed in class InputChannel

Throws:

IOException

getNumberOfQueuedBuffers

@VisibleForTesting
protected int getNumberOfQueuedBuffers()

requestBufferBlocking

public Buffer requestBufferBlocking()
                             throws InterruptedException,
                                    IOException

Throws:

InterruptedException

IOException

checkpointStarted

public void checkpointStarted(CheckpointBarrier barrier)
                       throws CheckpointException

Description copied from class: InputChannel

Called by task thread when checkpointing is started (e.g., any input channel received barrier).

Overrides:

checkpointStarted in class InputChannel

Throws:

CheckpointException