org.apache.flink.runtime.deployment

Class TaskDeploymentDescriptorFactory

java.lang.Object

org.apache.flink.runtime.deployment.TaskDeploymentDescriptorFactory

public class TaskDeploymentDescriptorFactory
extends Object

Factory of TaskDeploymentDescriptor to deploy Task from Execution.

Nested Class Summary

Nested Classes

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.
static class	TaskDeploymentDescriptorFactory.ShuffleDescriptorAndIndex This class represents the shuffle descriptor with it index in ConsumedPartitionGroup.

Method Summary

Modifier and Type	Method and Description
TaskDeploymentDescriptor	createDeploymentDescriptor(AllocationID allocationID, JobManagerTaskRestore taskRestore, Collection<ResultPartitionDeploymentDescriptor> producedPartitions)
static TaskDeploymentDescriptorFactory	fromExecution(Execution execution)
static ShuffleDescriptor	getConsumedPartitionShuffleDescriptor(IntermediateResultPartition consumedPartition, TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionDeploymentConstraint, boolean nonFinishedHybridPartitionShouldBeUnknown)

Methods inherited from class java.lang.Object

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

Method Detail

createDeploymentDescriptor

public TaskDeploymentDescriptor createDeploymentDescriptor(AllocationID allocationID,
                                                           @Nullable
                                                           JobManagerTaskRestore taskRestore,
                                                           Collection<ResultPartitionDeploymentDescriptor> producedPartitions)
                                                    throws IOException

Throws:

IOException

fromExecution

public static TaskDeploymentDescriptorFactory fromExecution(Execution execution)
                                                     throws IOException,
                                                            ClusterDatasetCorruptedException

Throws:

IOException

ClusterDatasetCorruptedException

getConsumedPartitionShuffleDescriptor

public static ShuffleDescriptor getConsumedPartitionShuffleDescriptor(IntermediateResultPartition consumedPartition,
                                                                      TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionDeploymentConstraint,
                                                                      boolean nonFinishedHybridPartitionShouldBeUnknown)