public class PartialInputChannelDeploymentDescriptor extends Object
This deployment descriptor is created in Execution.scheduleOrUpdateConsumers(java.util.List)
,
if the consumer instance is not yet clear. Once the instance on which the consumer runs is known,
the deployment descriptor is updated by completing the partition location.
Constructor and Description |
---|
PartialInputChannelDeploymentDescriptor(IntermediateDataSetID resultId,
ResultPartitionID partitionID,
TaskManagerLocation partitionTaskManagerLocation,
int partitionConnectionIndex) |
Modifier and Type | Method and Description |
---|---|
InputChannelDeploymentDescriptor |
createInputChannelDeploymentDescriptor(Execution consumerExecution)
Creates a channel deployment descriptor by completing the partition location.
|
static PartialInputChannelDeploymentDescriptor |
fromEdge(IntermediateResultPartition partition,
Execution producer)
Creates a partial input channel for the given partition and producing task.
|
IntermediateDataSetID |
getResultId() |
public PartialInputChannelDeploymentDescriptor(IntermediateDataSetID resultId, ResultPartitionID partitionID, TaskManagerLocation partitionTaskManagerLocation, int partitionConnectionIndex)
public InputChannelDeploymentDescriptor createInputChannelDeploymentDescriptor(Execution consumerExecution)
InputChannelDeploymentDescriptor
public IntermediateDataSetID getResultId()
public static PartialInputChannelDeploymentDescriptor fromEdge(IntermediateResultPartition partition, Execution producer)
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.