org.apache.flink.runtime.deployment

Class ResultPartitionDeploymentDescriptor

java.lang.Object

org.apache.flink.runtime.deployment.ResultPartitionDeploymentDescriptor

All Implemented Interfaces:

Serializable

public class ResultPartitionDeploymentDescriptor
extends Object
implements Serializable

Deployment descriptor for a result partition.

See Also:

ResultPartition, Serialized Form

Constructor Summary

Constructors

Constructor and Description
ResultPartitionDeploymentDescriptor(PartitionDescriptor partitionDescriptor, ShuffleDescriptor shuffleDescriptor, int maxParallelism)

Method Summary

Modifier and Type	Method and Description
int	getMaxParallelism()
int	getNumberOfSubpartitions()
IntermediateResultPartitionID	getPartitionId()
ResultPartitionType	getPartitionType()
IntermediateDataSetID	getResultId()
ShuffleDescriptor	getShuffleDescriptor()
int	getTotalNumberOfPartitions()
boolean	isBroadcast() Whether the resultPartition is a broadcast edge.
boolean	isNumberOfPartitionConsumerUndefined()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultPartitionDeploymentDescriptor

public ResultPartitionDeploymentDescriptor(PartitionDescriptor partitionDescriptor,
                                           ShuffleDescriptor shuffleDescriptor,
                                           int maxParallelism)

Method Detail

getResultId

public IntermediateDataSetID getResultId()

getPartitionId

public IntermediateResultPartitionID getPartitionId()

isBroadcast

public boolean isBroadcast()

Whether the resultPartition is a broadcast edge.

getPartitionType

public ResultPartitionType getPartitionType()

getTotalNumberOfPartitions

public int getTotalNumberOfPartitions()

getNumberOfSubpartitions

public int getNumberOfSubpartitions()

isNumberOfPartitionConsumerUndefined

public boolean isNumberOfPartitionConsumerUndefined()

getMaxParallelism

public int getMaxParallelism()

getShuffleDescriptor

public ShuffleDescriptor getShuffleDescriptor()

toString

public String toString()

Overrides:

toString in class Object