org.apache.flink.runtime.taskexecutor.partition

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 and Description
static class	ClusterPartitionReport.ClusterPartitionReportEntry An entry describing all partitions belonging to one dataset.

Constructor Summary

Constructors

Constructor and Description
ClusterPartitionReport(Collection<ClusterPartitionReport.ClusterPartitionReportEntry> entries)

Method Summary

Modifier and Type	Method and Description
Collection<ClusterPartitionReport.ClusterPartitionReportEntry>	getEntries()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ClusterPartitionReport

public ClusterPartitionReport(Collection<ClusterPartitionReport.ClusterPartitionReportEntry> entries)

Method Detail

getEntries

public Collection<ClusterPartitionReport.ClusterPartitionReportEntry> getEntries()

toString

public String toString()

Overrides:

toString in class Object