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.

Method Summary

Modifier and Type	Method and Description
TaskDeploymentDescriptor	createDeploymentDescriptor(AllocationID allocationID, int targetSlotNumber, JobManagerTaskRestore taskRestore, Collection<ResultPartitionDeploymentDescriptor> producedPartitions)
static TaskDeploymentDescriptorFactory	fromExecutionVertex(ExecutionVertex executionVertex, int attemptNumber)
static ShuffleDescriptor	getConsumedPartitionShuffleDescriptor(ExecutionEdge edge, boolean allowUnknownPartitions)

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,
                                                           int targetSlotNumber,
                                                           @Nullable
                                                           JobManagerTaskRestore taskRestore,
                                                           Collection<ResultPartitionDeploymentDescriptor> producedPartitions)

fromExecutionVertex

public static TaskDeploymentDescriptorFactory fromExecutionVertex(ExecutionVertex executionVertex,
                                                                  int attemptNumber)
                                                           throws IOException

Throws:

IOException

getConsumedPartitionShuffleDescriptor

public static ShuffleDescriptor getConsumedPartitionShuffleDescriptor(ExecutionEdge edge,
                                                                      boolean allowUnknownPartitions)