Uses of Package
org.apache.flink.runtime.io.network.partition.consumer

Packages that use org.apache.flink.runtime.io.network.partition.consumer

Package	Description
org.apache.flink.runtime.execution
org.apache.flink.runtime.io.network
org.apache.flink.runtime.io.network.api.reader
org.apache.flink.runtime.io.network.metrics
org.apache.flink.runtime.io.network.netty
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.shuffle
org.apache.flink.runtime.taskmanager
org.apache.flink.state.api.runtime
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

Classes in org.apache.flink.runtime.io.network.partition.consumer used by org.apache.flink.runtime.execution

Class and Description
IndexedInputGate An InputGate with a specific index.

Classes in org.apache.flink.runtime.io.network.partition.consumer used by org.apache.flink.runtime.io.network

Class and Description
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.
InputChannelID Identifier for input channels.
InputGate An input gate consumes one or more partitions of a single produced intermediate result.
InputGateID Runtime identifier of a consumed IntermediateResult.
RemoteInputChannel An input channel, which requests a remote partition queue.
SingleInputGate An input gate consumes one or more partitions of a single produced intermediate result.

Classes in org.apache.flink.runtime.io.network.partition.consumer used by org.apache.flink.runtime.io.network.api.reader

Class and Description
InputGate An input gate consumes one or more partitions of a single produced intermediate result.

Classes in org.apache.flink.runtime.io.network.partition.consumer used by org.apache.flink.runtime.io.network.metrics

Class and Description
InputGate An input gate consumes one or more partitions of a single produced intermediate result.
SingleInputGate An input gate consumes one or more partitions of a single produced intermediate result.

Classes in org.apache.flink.runtime.io.network.partition.consumer used by org.apache.flink.runtime.io.network.netty

Class and Description
RemoteInputChannel An input channel, which requests a remote partition queue.

Classes in org.apache.flink.runtime.io.network.partition.consumer used by org.apache.flink.runtime.io.network.partition.consumer

Class and Description
BufferManager The general buffer manager used by InputChannel to request/recycle exclusive or floating buffers.
BufferOrEvent Either type for Buffer or AbstractEvent instances tagged with the channel index, from which they were received.
EndOfChannelStateEvent This event marks a RecoveredInputChannel as fully consumed.
IndexedInputGate An InputGate with a specific index.
InputChannel An input channel consumes a single ResultSubpartitionView.
InputChannelID Identifier for input channels.
InputGate An input gate consumes one or more partitions of a single produced intermediate result.
RecoveredInputChannel An input channel reads recovered state from previous unaligned checkpoint snapshots via ChannelStateReader.
SingleInputGate An input gate consumes one or more partitions of a single produced intermediate result.
SingleInputGateFactory.ChannelStatistics Statistics of input channels.

Classes in org.apache.flink.runtime.io.network.partition.consumer used by org.apache.flink.runtime.shuffle

Class and Description
IndexedInputGate An InputGate with a specific index.

Classes in org.apache.flink.runtime.io.network.partition.consumer used by org.apache.flink.runtime.taskmanager

Class and Description
BufferOrEvent Either type for Buffer or AbstractEvent instances tagged with the channel index, from which they were received.
IndexedInputGate An InputGate with a specific index.
InputChannel An input channel consumes a single ResultSubpartitionView.
InputGate An input gate consumes one or more partitions of a single produced intermediate result.

Classes in org.apache.flink.runtime.io.network.partition.consumer used by org.apache.flink.state.api.runtime

Class and Description
IndexedInputGate An InputGate with a specific index.

Classes in org.apache.flink.runtime.io.network.partition.consumer used by org.apache.flink.streaming.runtime.io

Class and Description
BufferOrEvent Either type for Buffer or AbstractEvent instances tagged with the channel index, from which they were received.
IndexedInputGate An InputGate with a specific index.
InputChannel An input channel consumes a single ResultSubpartitionView.
InputGate An input gate consumes one or more partitions of a single produced intermediate result.

Classes in org.apache.flink.runtime.io.network.partition.consumer used by org.apache.flink.streaming.runtime.tasks

Class and Description
IndexedInputGate An InputGate with a specific index.