public interface PartitionReleaseStrategy
IntermediateResultPartitions
.Modifier and Type | Interface and Description |
---|---|
static interface |
PartitionReleaseStrategy.Factory
Factory for
PartitionReleaseStrategy . |
Modifier and Type | Method and Description |
---|---|
List<IntermediateResultPartitionID> |
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.
|
List<IntermediateResultPartitionID> vertexFinished(ExecutionVertexID finishedVertex)
finishedVertex
- Id of the vertex that finished the executionvoid vertexUnfinished(ExecutionVertexID executionVertexID)
executionVertexID
- Id of the vertex that is no longer in finished state.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.