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

Class LocalInputChannel

java.lang.Object

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

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

All Implemented Interfaces:

BufferAvailabilityListener

public class LocalInputChannel
extends InputChannel
implements BufferAvailabilityListener

An input channel, which requests a local subpartition.

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

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

Constructor Summary

Constructors

Constructor and Description
LocalInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ResultPartitionManager partitionManager, TaskEventPublisher taskEventPublisher, Counter numBytesIn, Counter numBuffersIn)
LocalInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, ResultPartitionManager partitionManager, TaskEventPublisher taskEventPublisher, int initialBackoff, int maxBackoff, Counter numBytesIn, Counter numBuffersIn)

Method Summary

Modifier and Type	Method and Description
void	notifyDataAvailable() Called whenever there might be new data available.
boolean	notifyPriorityEvent(BufferConsumer eventBufferConsumer) Allows the listener to react to a priority event before it is added to the outgoing buffer queue.
protected void	requestSubpartition(int subpartitionIndex) Requests the queue with the specified index of the source intermediate result partition.
void	resumeConsumption() After sending a CheckpointBarrier of exactly-once mode, the upstream will be blocked and become unavailable.
void	spillInflightBuffers(long checkpointId, ChannelStateWriter channelStateWriter)
String	toString()
int	unsynchronizedGetNumberOfQueuedBuffers()

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalInputChannel

public LocalInputChannel(SingleInputGate inputGate,
                         int channelIndex,
                         ResultPartitionID partitionId,
                         ResultPartitionManager partitionManager,
                         TaskEventPublisher taskEventPublisher,
                         Counter numBytesIn,
                         Counter numBuffersIn)

LocalInputChannel

public LocalInputChannel(SingleInputGate inputGate,
                         int channelIndex,
                         ResultPartitionID partitionId,
                         ResultPartitionManager partitionManager,
                         TaskEventPublisher taskEventPublisher,
                         int initialBackoff,
                         int maxBackoff,
                         Counter numBytesIn,
                         Counter numBuffersIn)

Method Detail

requestSubpartition

protected void requestSubpartition(int subpartitionIndex)
                            throws IOException

Description copied from class: InputChannel

Requests the queue with the specified index of the source intermediate result partition.

The queue index to request depends on which sub task the channel belongs to and is specified by the consumer of this channel.

Throws:

IOException

spillInflightBuffers

public void spillInflightBuffers(long checkpointId,
                                 ChannelStateWriter channelStateWriter)

Overrides:

spillInflightBuffers in class InputChannel

notifyDataAvailable

public void notifyDataAvailable()

Description copied from interface: BufferAvailabilityListener

Called whenever there might be new data available.

Specified by:

notifyDataAvailable in interface BufferAvailabilityListener

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

unsynchronizedGetNumberOfQueuedBuffers

public int unsynchronizedGetNumberOfQueuedBuffers()

Overrides:

unsynchronizedGetNumberOfQueuedBuffers in class InputChannel

toString

public String toString()

Overrides:

toString in class Object

notifyPriorityEvent

public boolean notifyPriorityEvent(BufferConsumer eventBufferConsumer)
                            throws IOException

Description copied from interface: BufferAvailabilityListener

Allows the listener to react to a priority event before it is added to the outgoing buffer queue.

Specified by:

notifyPriorityEvent in interface BufferAvailabilityListener

Returns:

true if the event has been fully processed and should not be added to the buffer queue.

Throws:

IOException