Uses of Interface
org.apache.flink.runtime.io.PullingAsyncDataInput

Packages that use PullingAsyncDataInput

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

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

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

Modifier and Type	Class and Description
class	InputGate An input gate consumes one or more partitions of a single produced intermediate result.
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 PullingAsyncDataInput in org.apache.flink.runtime.taskmanager

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

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.

Uses of PullingAsyncDataInput in org.apache.flink.streaming.runtime.io

Classes in org.apache.flink.streaming.runtime.io that implement PullingAsyncDataInput

Modifier and Type	Class and Description
class	CheckpointedInputGate The CheckpointedInputGate uses CheckpointBarrierHandler to handle incoming CheckpointBarrier from the InputGate.