public class ResultPartitionDeploymentDescriptor extends Object implements Serializable
ResultPartition
,
Serialized FormConstructor and Description |
---|
ResultPartitionDeploymentDescriptor(IntermediateDataSetID resultId,
IntermediateResultPartitionID partitionId,
ResultPartitionType partitionType,
int numberOfSubpartitions,
boolean sendScheduleOrUpdateConsumersMessage) |
Modifier and Type | Method and Description |
---|---|
static ResultPartitionDeploymentDescriptor |
from(IntermediateResultPartition partition,
boolean lazyScheduling) |
int |
getNumberOfSubpartitions() |
IntermediateResultPartitionID |
getPartitionId() |
ResultPartitionType |
getPartitionType() |
IntermediateDataSetID |
getResultId() |
boolean |
sendScheduleOrUpdateConsumersMessage() |
String |
toString() |
public ResultPartitionDeploymentDescriptor(IntermediateDataSetID resultId, IntermediateResultPartitionID partitionId, ResultPartitionType partitionType, int numberOfSubpartitions, boolean sendScheduleOrUpdateConsumersMessage)
public IntermediateDataSetID getResultId()
public IntermediateResultPartitionID getPartitionId()
public ResultPartitionType getPartitionType()
public int getNumberOfSubpartitions()
public boolean sendScheduleOrUpdateConsumersMessage()
public static ResultPartitionDeploymentDescriptor from(IntermediateResultPartition partition, boolean lazyScheduling)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.