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 |
---|---|
static SubpartitionIndexRange |
computeConsumedSubpartitionRange(int numConsumers,
IntermediateResultPartition resultPartition,
int consumerSubtaskIndex) |
TaskDeploymentDescriptor |
createDeploymentDescriptor(AllocationID allocationID,
JobManagerTaskRestore taskRestore,
Collection<ResultPartitionDeploymentDescriptor> producedPartitions) |
static TaskDeploymentDescriptorFactory |
fromExecution(Execution execution) |
static ShuffleDescriptor |
getConsumedPartitionShuffleDescriptor(IntermediateResultPartition consumedPartition,
TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionDeploymentConstraint) |
public TaskDeploymentDescriptor createDeploymentDescriptor(AllocationID allocationID, @Nullable JobManagerTaskRestore taskRestore, Collection<ResultPartitionDeploymentDescriptor> producedPartitions) throws IOException
IOException
public static SubpartitionIndexRange computeConsumedSubpartitionRange(int numConsumers, IntermediateResultPartition resultPartition, int consumerSubtaskIndex)
public static TaskDeploymentDescriptorFactory fromExecution(Execution execution) throws IOException, ClusterDatasetCorruptedException
public static ShuffleDescriptor getConsumedPartitionShuffleDescriptor(IntermediateResultPartition consumedPartition, TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionDeploymentConstraint)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.