Uses of Interface
org.apache.flink.runtime.io.network.partition.consumer.CheckpointableInput
-
Packages that use CheckpointableInput Package Description org.apache.flink.runtime.io.network.partition.consumer org.apache.flink.runtime.taskmanager -
-
Uses of CheckpointableInput in org.apache.flink.runtime.io.network.partition.consumer
Classes in org.apache.flink.runtime.io.network.partition.consumer that implement CheckpointableInput Modifier and Type Class Description classIndexedInputGateAnInputGatewith a specific index.classSingleInputGateAn input gate consumes one or more partitions of a single produced intermediate result. -
Uses of CheckpointableInput in org.apache.flink.runtime.taskmanager
Classes in org.apache.flink.runtime.taskmanager that implement CheckpointableInput Modifier and Type Class Description classInputGateWithMetricsThis class wrapsInputGateprovided by shuffle service and it is mainly used for increasing general input metrics fromTaskIOMetricGroup.
-