Modifier and Type | Method and Description |
---|---|
ResultPartitionType |
InputGateDeploymentDescriptor.getConsumedPartitionType()
Returns the type of this input channel's consumed result partition.
|
ResultPartitionType |
ResultPartitionDeploymentDescriptor.getPartitionType() |
Constructor and Description |
---|
InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId,
ResultPartitionType consumedPartitionType,
int consumedSubpartitionIndex,
InputChannelDeploymentDescriptor[] inputChannels) |
ResultPartitionDeploymentDescriptor(IntermediateDataSetID resultId,
IntermediateResultPartitionID partitionId,
ResultPartitionType partitionType,
int numberOfSubpartitions,
int maxParallelism,
boolean lazyScheduling) |
Modifier and Type | Method and Description |
---|---|
ResultPartitionType |
IntermediateResult.getResultType() |
Constructor and Description |
---|
IntermediateResult(IntermediateDataSetID id,
ExecutionJobVertex producer,
int numParallelProducers,
ResultPartitionType resultType) |
Modifier and Type | Method and Description |
---|---|
ResultPartitionType |
ResultPartition.getPartitionType()
Returns the type of this result partition.
|
static ResultPartitionType |
ResultPartitionType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ResultPartitionType[] |
ResultPartitionType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
ResultPartition(String owningTaskName,
TaskActions taskActions,
JobID jobId,
ResultPartitionID partitionId,
ResultPartitionType partitionType,
int numberOfSubpartitions,
int numTargetKeyGroups,
ResultPartitionManager partitionManager,
ResultPartitionConsumableNotifier partitionConsumableNotifier,
IOManager ioManager,
boolean sendScheduleOrUpdateConsumersMessage) |
Modifier and Type | Method and Description |
---|---|
ResultPartitionType |
SingleInputGate.getConsumedPartitionType()
Returns the type of this input channel's consumed result partition.
|
Constructor and Description |
---|
SingleInputGate(String owningTaskName,
JobID jobId,
IntermediateDataSetID consumedResultId,
ResultPartitionType consumedPartitionType,
int consumedSubpartitionIndex,
int numberOfInputChannels,
TaskActions taskActions,
TaskIOMetricGroup metrics,
boolean isCreditBased) |
Modifier and Type | Method and Description |
---|---|
ResultPartitionType |
IntermediateDataSet.getResultType() |
Modifier and Type | Method and Description |
---|---|
JobEdge |
JobVertex.connectNewDataSetAsInput(JobVertex input,
DistributionPattern distPattern,
ResultPartitionType partitionType) |
IntermediateDataSet |
JobVertex.createAndAddResultDataSet(IntermediateDataSetID id,
ResultPartitionType partitionType) |
IntermediateDataSet |
JobVertex.createAndAddResultDataSet(ResultPartitionType partitionType) |
Constructor and Description |
---|
IntermediateDataSet(IntermediateDataSetID id,
ResultPartitionType resultType,
JobVertex producer) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.