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

Class IndexedInputGate

java.lang.Object

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

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

All Implemented Interfaces:

AutoCloseable, AvailabilityProvider, PullingAsyncDataInput<BufferOrEvent>

Direct Known Subclasses:

InputGateWithMetrics, SingleInputGate

public abstract class IndexedInputGate
extends InputGate

An InputGate with a specific index.

Nested Class Summary

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

InputGate.InputWithData<INPUT,DATA>

Nested classes/interfaces inherited from interface org.apache.flink.runtime.io.AvailabilityProvider

AvailabilityProvider.AvailabilityHelper

Field Summary

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

availabilityHelper

Fields inherited from interface org.apache.flink.runtime.io.AvailabilityProvider

AVAILABLE

Constructor Summary

Constructors

Constructor and Description
IndexedInputGate()

Method Summary

Modifier and Type	Method and Description
abstract int	getGateIndex() Returns the index of this input gate.

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

getAvailableFuture, getChannel, getChannelInfos, getNext, getNumberOfInputChannels, isFinished, pollNext, readRecoveredState, registerBufferReceivedListener, requestPartitions, resumeConsumption, sendTaskEvent, setup

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.runtime.io.AvailabilityProvider

isApproximatelyAvailable, isAvailable

Methods inherited from interface java.lang.AutoCloseable

close

Constructor Detail

IndexedInputGate

public IndexedInputGate()

Method Detail

getGateIndex

public abstract int getGateIndex()

Returns the index of this input gate. Only supported on