org.apache.flink.runtime.executiongraph.failover.flip1.partitionrelease

Class RegionPartitionReleaseStrategy

java.lang.Object

org.apache.flink.runtime.executiongraph.failover.flip1.partitionrelease.RegionPartitionReleaseStrategy

All Implemented Interfaces:

PartitionReleaseStrategy

public class RegionPartitionReleaseStrategy
extends Object
implements PartitionReleaseStrategy

Releases blocking intermediate result partitions that are incident to a SchedulingPipelinedRegion, as soon as the region's execution vertices are finished.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RegionPartitionReleaseStrategy.Factory Factory for PartitionReleaseStrategy.

Constructor Summary

Constructors

Constructor and Description
RegionPartitionReleaseStrategy(SchedulingTopology schedulingTopology)

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RegionPartitionReleaseStrategy

public RegionPartitionReleaseStrategy(SchedulingTopology schedulingTopology)

Method Detail

vertexFinished

public List<IntermediateResultPartitionID> vertexFinished(ExecutionVertexID finishedVertex)

Description copied from interface: PartitionReleaseStrategy

Calling this method informs the strategy that a vertex finished.

Specified by:

vertexFinished in interface PartitionReleaseStrategy

Parameters:

finishedVertex - Id of the vertex that finished the execution

Returns:

A list of result partitions that can be released

vertexUnfinished

public void vertexUnfinished(ExecutionVertexID executionVertexId)

Description copied from interface: PartitionReleaseStrategy

Calling this method informs the strategy that a vertex is no longer in finished state, e.g., when a vertex is re-executed.

Specified by:

vertexUnfinished in interface PartitionReleaseStrategy

Parameters:

executionVertexId - Id of the vertex that is no longer in finished state.