public class InputGateDeploymentDescriptor extends Object implements Serializable
Each input gate consumes partitions of a single intermediate result. The consumed subpartition index range is the same for each consumed partition.
SingleInputGate
,
Serialized FormConstructor and Description |
---|
InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId,
ResultPartitionType consumedPartitionType,
IndexRange consumedSubpartitionIndexRange,
int numberOfInputChannels,
List<TaskDeploymentDescriptor.MaybeOffloaded<TaskDeploymentDescriptorFactory.ShuffleDescriptorAndIndex[]>> serializedInputChannels) |
InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId,
ResultPartitionType consumedPartitionType,
int consumedSubpartitionIndex,
TaskDeploymentDescriptorFactory.ShuffleDescriptorAndIndex[] inputChannels) |
Modifier and Type | Method and Description |
---|---|
ResultPartitionType |
getConsumedPartitionType()
Returns the type of this input channel's consumed result partition.
|
IntermediateDataSetID |
getConsumedResultId() |
int |
getConsumedSubpartitionIndex() |
IndexRange |
getConsumedSubpartitionIndexRange()
Return the index range of the the consumed subpartitions.
|
ShuffleDescriptor[] |
getShuffleDescriptors() |
void |
loadBigData(PermanentBlobService blobService,
JobID jobId) |
String |
toString() |
@VisibleForTesting public InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId, ResultPartitionType consumedPartitionType, @Nonnegative int consumedSubpartitionIndex, TaskDeploymentDescriptorFactory.ShuffleDescriptorAndIndex[] inputChannels) throws IOException
IOException
public InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId, ResultPartitionType consumedPartitionType, IndexRange consumedSubpartitionIndexRange, int numberOfInputChannels, List<TaskDeploymentDescriptor.MaybeOffloaded<TaskDeploymentDescriptorFactory.ShuffleDescriptorAndIndex[]>> serializedInputChannels)
public IntermediateDataSetID getConsumedResultId()
public ResultPartitionType getConsumedPartitionType()
@Nonnegative public int getConsumedSubpartitionIndex()
public IndexRange getConsumedSubpartitionIndexRange()
public void loadBigData(@Nullable PermanentBlobService blobService, JobID jobId) throws IOException
IOException
public ShuffleDescriptor[] getShuffleDescriptors()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.