Modifier and Type | Method and Description |
---|---|
ConsumedPartitionGroup |
ExecutionVertex.getConsumedPartitionGroup(int input) |
Modifier and Type | Method and Description |
---|---|
List<ConsumedPartitionGroup> |
ExecutionVertex.getAllConsumedPartitionGroups() |
List<ConsumedPartitionGroup> |
IntermediateResultPartition.getConsumedPartitionGroups() |
List<ConsumedPartitionGroup> |
EdgeManager.getConsumedPartitionGroupsById(IntermediateResultPartitionID resultPartitionId) |
List<ConsumedPartitionGroup> |
EdgeManager.getConsumedPartitionGroupsForVertex(ExecutionVertexID executionVertexId) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionVertex.addConsumedPartitionGroup(ConsumedPartitionGroup consumedPartitions) |
void |
IntermediateResult.cacheShuffleDescriptors(ConsumedPartitionGroup consumedPartitionGroup,
TaskDeploymentDescriptor.MaybeOffloaded<ShuffleDescriptor[]> shuffleDescriptors) |
void |
IntermediateResult.clearCachedInformationForPartitionGroup(ConsumedPartitionGroup consumedPartitionGroup) |
void |
EdgeManager.connectVertexWithConsumedPartitionGroup(ExecutionVertexID executionVertexId,
ConsumedPartitionGroup consumedPartitionGroup) |
TaskDeploymentDescriptor.MaybeOffloaded<ShuffleDescriptor[]> |
IntermediateResult.getCachedShuffleDescriptors(ConsumedPartitionGroup consumedPartitionGroup) |
void |
EdgeManager.registerConsumedPartitionGroup(ConsumedPartitionGroup group) |
Modifier and Type | Method and Description |
---|---|
List<ConsumedPartitionGroup> |
PartitionGroupReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex)
Calling this method informs the strategy that a vertex finished.
|
List<ConsumedPartitionGroup> |
NotReleasingPartitionGroupReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex) |
List<ConsumedPartitionGroup> |
RegionPartitionGroupReleaseStrategy.vertexFinished(ExecutionVertexID finishedVertex) |
Modifier and Type | Method and Description |
---|---|
Iterable<ConsumedPartitionGroup> |
DefaultSchedulingPipelinedRegion.getAllBlockingConsumedPartitionGroups() |
Modifier and Type | Method and Description |
---|---|
static ConsumedPartitionGroup |
ConsumedPartitionGroup.fromMultiplePartitions(List<IntermediateResultPartitionID> resultPartitions) |
static ConsumedPartitionGroup |
ConsumedPartitionGroup.fromSinglePartition(IntermediateResultPartitionID resultPartition) |
Modifier and Type | Method and Description |
---|---|
Iterable<ConsumedPartitionGroup> |
SchedulingPipelinedRegion.getAllBlockingConsumedPartitionGroups()
Get all distinct blocking
ConsumedPartitionGroup s. |
List<ConsumedPartitionGroup> |
SchedulingResultPartition.getConsumedPartitionGroups()
Gets the
ConsumedPartitionGroup s this partition belongs to. |
List<ConsumedPartitionGroup> |
SchedulingExecutionVertex.getConsumedPartitionGroups()
Gets the
ConsumedPartitionGroup s. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.