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(IntermediateDataSetID resultId, IntermediateResultPartitionID partitionId, ResultPartitionType partitionType, int numberOfSubpartitions, boolean eagerlyDeployConsumers)

Method Summary

Modifier and Type	Method and Description
static ResultPartitionDeploymentDescriptor	from(IntermediateResultPartition partition)
boolean	getEagerlyDeployConsumers() Returns whether consumers should be deployed eagerly (as soon as they are registered at the result manager of the task manager).
int	getNumberOfSubpartitions()
IntermediateResultPartitionID	getPartitionId()
ResultPartitionType	getPartitionType()
IntermediateDataSetID	getResultId()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultPartitionDeploymentDescriptor

public ResultPartitionDeploymentDescriptor(IntermediateDataSetID resultId,
                                           IntermediateResultPartitionID partitionId,
                                           ResultPartitionType partitionType,
                                           int numberOfSubpartitions,
                                           boolean eagerlyDeployConsumers)

Method Detail

getResultId

public IntermediateDataSetID getResultId()

getPartitionId

public IntermediateResultPartitionID getPartitionId()

getPartitionType

public ResultPartitionType getPartitionType()

getNumberOfSubpartitions

public int getNumberOfSubpartitions()

getEagerlyDeployConsumers

public boolean getEagerlyDeployConsumers()

Returns whether consumers should be deployed eagerly (as soon as they are registered at the result manager of the task manager).

Returns:

Whether consumers should be deployed eagerly

toString

public String toString()

Overrides:

toString in class Object

from

public static ResultPartitionDeploymentDescriptor from(IntermediateResultPartition partition)