Package org.apache.flink.runtime.shuffle

Class DefaultPartitionWithMetrics

java.lang.Object

org.apache.flink.runtime.shuffle.DefaultPartitionWithMetrics

All Implemented Interfaces:

Serializable, PartitionWithMetrics

public class DefaultPartitionWithMetrics
extends Object
implements PartitionWithMetrics

Default PartitionWithMetrics implementation.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
DefaultPartitionWithMetrics(ShuffleDescriptor shuffleDescriptor, ShuffleMetrics partitionMetrics)

Method Summary

Modifier and Type	Method	Description
ShuffleDescriptor	getPartition()
ShuffleMetrics	getPartitionMetrics()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultPartitionWithMetrics

public DefaultPartitionWithMetrics(ShuffleDescriptor shuffleDescriptor,
                                   ShuffleMetrics partitionMetrics)

Method Detail

getPartitionMetrics

public ShuffleMetrics getPartitionMetrics()

Specified by:

getPartitionMetrics in interface PartitionWithMetrics

getPartition

public ShuffleDescriptor getPartition()

Specified by:

getPartition in interface PartitionWithMetrics