public class RegionPartitionGroupReleaseStrategy extends Object implements PartitionGroupReleaseStrategy
SchedulingPipelinedRegion
, as soon as the region's execution vertices are finished.Modifier and Type | Class and Description |
---|---|
static class |
RegionPartitionGroupReleaseStrategy.Factory
Factory for
PartitionGroupReleaseStrategy . |
Constructor and Description |
---|
RegionPartitionGroupReleaseStrategy(SchedulingTopology schedulingTopology) |
Modifier and Type | Method and Description |
---|---|
List<ConsumedPartitionGroup> |
vertexFinished(ExecutionVertexID finishedVertex)
Calling this method informs the strategy that a vertex finished.
|
void |
vertexUnfinished(ExecutionVertexID executionVertexId)
Calling this method informs the strategy that a vertex is no longer in finished state, e.g.,
when a vertex is re-executed.
|
public RegionPartitionGroupReleaseStrategy(SchedulingTopology schedulingTopology)
public List<ConsumedPartitionGroup> vertexFinished(ExecutionVertexID finishedVertex)
PartitionGroupReleaseStrategy
vertexFinished
in interface PartitionGroupReleaseStrategy
finishedVertex
- Id of the vertex that finished the executionConsumedPartitionGroups
that can be releasedpublic void vertexUnfinished(ExecutionVertexID executionVertexId)
PartitionGroupReleaseStrategy
vertexUnfinished
in interface PartitionGroupReleaseStrategy
executionVertexId
- Id of the vertex that is no longer in finished state.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.