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, UnknownInputChannel

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()

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	InputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId)

Method Summary

Modifier and Type	Method and Description
protected void	notifyAvailableBuffer() Notifies the owning SingleInputGate about an available Buffer instance.

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

Constructor Detail

InputChannel

protected InputChannel(SingleInputGate inputGate,
                       int channelIndex,
                       ResultPartitionID partitionId)

Method Detail

notifyAvailableBuffer

protected void notifyAvailableBuffer()

Notifies the owning SingleInputGate about an available Buffer instance.