Interface PartitionGroupReleaseStrategy
-
- All Known Implementing Classes:
NotReleasingPartitionGroupReleaseStrategy
,RegionPartitionGroupReleaseStrategy
public interface PartitionGroupReleaseStrategy
Interface for strategies that decide when to releaseConsumedPartitionGroups
.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interface
PartitionGroupReleaseStrategy.Factory
Factory forPartitionGroupReleaseStrategy
.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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.
-
-
-
Method Detail
-
vertexFinished
List<ConsumedPartitionGroup> vertexFinished(ExecutionVertexID finishedVertex)
Calling this method informs the strategy that a vertex finished.- Parameters:
finishedVertex
- Id of the vertex that finished the execution- Returns:
- A list of
ConsumedPartitionGroups
that can be released
-
vertexUnfinished
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.- Parameters:
executionVertexID
- Id of the vertex that is no longer in finished state.
-
-