Class ClusterPartitionReport
- java.lang.Object
-
- org.apache.flink.runtime.taskexecutor.partition.ClusterPartitionReport
-
- All Implemented Interfaces:
Serializable
public class ClusterPartitionReport extends Object implements Serializable
A report about the current status of all cluster partitions of the TaskExecutor, describing which partitions are available.- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ClusterPartitionReport.ClusterPartitionReportEntry
An entry describing all partitions belonging to one dataset.
-
Constructor Summary
Constructors Constructor Description ClusterPartitionReport(Collection<ClusterPartitionReport.ClusterPartitionReportEntry> entries)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Collection<ClusterPartitionReport.ClusterPartitionReportEntry>
getEntries()
String
toString()
-
-
-
Constructor Detail
-
ClusterPartitionReport
public ClusterPartitionReport(Collection<ClusterPartitionReport.ClusterPartitionReportEntry> entries)
-
-
Method Detail
-
getEntries
public Collection<ClusterPartitionReport.ClusterPartitionReportEntry> getEntries()
-
-