public class InputGateDeploymentDescriptor extends Object implements Serializable
Each input gate consumes partitions of a single intermediate result. The consumed subpartition index is the same for each consumed partition.
SingleInputGate
,
Serialized FormConstructor and Description |
---|
InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId,
ResultPartitionType consumedPartitionType,
int consumedSubpartitionIndex,
InputChannelDeploymentDescriptor[] inputChannels) |
Modifier and Type | Method and Description |
---|---|
ResultPartitionType |
getConsumedPartitionType()
Returns the type of this input channel's consumed result partition.
|
IntermediateDataSetID |
getConsumedResultId() |
int |
getConsumedSubpartitionIndex() |
InputChannelDeploymentDescriptor[] |
getInputChannelDeploymentDescriptors() |
String |
toString() |
public InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId, ResultPartitionType consumedPartitionType, int consumedSubpartitionIndex, InputChannelDeploymentDescriptor[] inputChannels)
public IntermediateDataSetID getConsumedResultId()
public ResultPartitionType getConsumedPartitionType()
public int getConsumedSubpartitionIndex()
public InputChannelDeploymentDescriptor[] getInputChannelDeploymentDescriptors()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.