public class TaskDeploymentDescriptorFactory extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TaskDeploymentDescriptorFactory.PartitionLocationConstraint
Defines whether the partition's location must be known at deployment time or can be unknown
and, therefore, updated later.
|
Modifier and Type | Method and Description |
---|---|
TaskDeploymentDescriptor |
createDeploymentDescriptor(AllocationID allocationID,
JobManagerTaskRestore taskRestore,
Collection<ResultPartitionDeploymentDescriptor> producedPartitions) |
static TaskDeploymentDescriptorFactory |
fromExecutionVertex(ExecutionVertex executionVertex,
int attemptNumber) |
static ShuffleDescriptor |
getConsumedPartitionShuffleDescriptor(IntermediateResultPartition consumedPartition,
TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionDeploymentConstraint) |
public TaskDeploymentDescriptor createDeploymentDescriptor(AllocationID allocationID, @Nullable JobManagerTaskRestore taskRestore, Collection<ResultPartitionDeploymentDescriptor> producedPartitions)
public static TaskDeploymentDescriptorFactory fromExecutionVertex(ExecutionVertex executionVertex, int attemptNumber) throws IOException
IOException
public static ShuffleDescriptor getConsumedPartitionShuffleDescriptor(IntermediateResultPartition consumedPartition, TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionDeploymentConstraint)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.