Uses of Interface
org.apache.flink.runtime.io.network.partition.ChannelStateHolder

Packages that use ChannelStateHolder

Package	Description
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.taskmanager

Uses of ChannelStateHolder in org.apache.flink.runtime.io.network.partition

Classes in org.apache.flink.runtime.io.network.partition that implement ChannelStateHolder

Modifier and Type	Class and Description
class	PipelinedApproximateSubpartition A pipelined in-memory only subpartition, which allows to reconnect after failure.
class	PipelinedResultPartition A result output of a task, pipelined (streamed) to the receivers.
class	PipelinedSubpartition A pipelined in-memory only subpartition, which can be consumed once.

Uses of ChannelStateHolder in org.apache.flink.runtime.io.network.partition.consumer

Classes in org.apache.flink.runtime.io.network.partition.consumer that implement ChannelStateHolder

Modifier and Type	Class and Description
class	IndexedInputGate An InputGate with a specific index.
class	InputGate An input gate consumes one or more partitions of a single produced intermediate result.
class	LocalRecoveredInputChannel An input channel reads recovered state from previous unaligned checkpoint snapshots and then converts into LocalInputChannel finally.
class	RecoveredInputChannel An input channel reads recovered state from previous unaligned checkpoint snapshots.
class	RemoteRecoveredInputChannel An input channel reads recovered state from previous unaligned checkpoint snapshots and then converts into RemoteInputChannel finally.
class	SingleInputGate An input gate consumes one or more partitions of a single produced intermediate result.
class	UnionInputGate Input gate wrapper to union the input from multiple input gates.

Uses of ChannelStateHolder in org.apache.flink.runtime.taskmanager

Classes in org.apache.flink.runtime.taskmanager that implement ChannelStateHolder

Modifier and Type	Class and Description
class	InputGateWithMetrics This class wraps InputGate provided by shuffle service and it is mainly used for increasing general input metrics from TaskIOMetricGroup.