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

Class InputChannel

java.lang.Object

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

Direct Known Subclasses:

LocalInputChannel, RemoteInputChannel

public abstract class InputChannel
extends Object

An input channel consumes a single ResultSubpartitionView.

For each channel, the consumption life cycle is as follows:

1. requestSubpartition(int)
2. getNextBuffer()
3. releaseAllResources()

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InputChannel.BufferAndAvailability A combination of a Buffer and a flag indicating availability of further buffers, and the backlog length indicating how many non-event buffers are available in the subpartition.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	channelIndex
protected SingleInputGate	inputGate
protected Counter	numBuffersIn
protected Counter	numBytesIn
protected ResultPartitionID	partitionId

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	InputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, int initialBackoff, int maxBackoff, Counter numBytesIn, Counter numBuffersIn)

Method Summary

Modifier and Type	Method and Description
protected void	checkError() Checks for an error and rethrows it if one was reported.
protected int	getCurrentBackoff() Returns the current backoff in ms.
ResultPartitionID	getPartitionId()
protected boolean	increaseBackoff() Increases the current backoff and returns whether the operation was successful.
protected void	notifyChannelNonEmpty() Notifies the owning SingleInputGate that this channel became non-empty.
protected void	setError(Throwable cause) Atomically sets an error for this channel and notifies the input gate about available data to trigger querying this channel by the task thread.

Methods inherited from class java.lang.Object

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

Field Detail

channelIndex

protected final int channelIndex

partitionId

protected final ResultPartitionID partitionId

inputGate

protected final SingleInputGate inputGate

numBytesIn

protected final Counter numBytesIn

numBuffersIn

protected final Counter numBuffersIn

Constructor Detail

InputChannel

protected InputChannel(SingleInputGate inputGate,
                       int channelIndex,
                       ResultPartitionID partitionId,
                       int initialBackoff,
                       int maxBackoff,
                       Counter numBytesIn,
                       Counter numBuffersIn)

Method Detail

getPartitionId

public ResultPartitionID getPartitionId()

notifyChannelNonEmpty

protected void notifyChannelNonEmpty()

Notifies the owning SingleInputGate that this channel became non-empty.

This is guaranteed to be called only when a Buffer was added to a previously empty input channel. The notion of empty is atomically consistent with the flag InputChannel.BufferAndAvailability.moreAvailable() when polling the next buffer from this channel.

Note: When the input channel observes an exception, this method is called regardless of whether the channel was empty before. That ensures that the parent InputGate will always be notified about the exception.

checkError

protected void checkError()
                   throws IOException

Checks for an error and rethrows it if one was reported.

Throws:

IOException

setError

protected void setError(Throwable cause)

Atomically sets an error for this channel and notifies the input gate about available data to trigger querying this channel by the task thread.

getCurrentBackoff

protected int getCurrentBackoff()

Returns the current backoff in ms.

increaseBackoff

protected boolean increaseBackoff()

Increases the current backoff and returns whether the operation was successful.

Returns:

true, iff the operation was successful. Otherwise, false.