Package org.apache.flink.runtime.taskexecutor.partition
-
Class Summary Class Description ClusterPartitionReport A report about the current status of all cluster partitions of the TaskExecutor, describing which partitions are available.ClusterPartitionReport.ClusterPartitionReportEntry An entry describing all partitions belonging to one dataset.PartitionTable<K> Thread-safe Utility for tracking partitions.