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

Class RegionPartitionGroupReleaseStrategy

java.lang.Object

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

All Implemented Interfaces:

PartitionGroupReleaseStrategy, SchedulingTopologyListener

public class RegionPartitionGroupReleaseStrategy
extends Object
implements PartitionGroupReleaseStrategy, SchedulingTopologyListener

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	Description
static class	RegionPartitionGroupReleaseStrategy.Factory	Factory for PartitionGroupReleaseStrategy.

Constructor Summary

Constructors

Constructor	Description
RegionPartitionGroupReleaseStrategy(SchedulingTopology schedulingTopology)

Method Summary

Modifier and Type	Method	Description
boolean	isRegionOfVertexFinished(ExecutionVertexID executionVertexId)
void	notifySchedulingTopologyUpdated(SchedulingTopology schedulingTopology, List<ExecutionVertexID> newExecutionVertices)	Notifies that the scheduling topology is just updated.
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.

Methods inherited from class java.lang.Object

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

Constructor Detail

RegionPartitionGroupReleaseStrategy

public RegionPartitionGroupReleaseStrategy(SchedulingTopology schedulingTopology)

Method Detail

vertexFinished

public List<ConsumedPartitionGroup> vertexFinished(ExecutionVertexID finishedVertex)

Description copied from interface: PartitionGroupReleaseStrategy

Calling this method informs the strategy that a vertex finished.

Specified by:

vertexFinished in interface PartitionGroupReleaseStrategy

Parameters:

finishedVertex - Id of the vertex that finished the execution

Returns:

A list of ConsumedPartitionGroups that can be released

vertexUnfinished

public void vertexUnfinished(ExecutionVertexID executionVertexId)

Description copied from interface: PartitionGroupReleaseStrategy

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 PartitionGroupReleaseStrategy

Parameters:

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

isRegionOfVertexFinished

@VisibleForTesting
public boolean isRegionOfVertexFinished(ExecutionVertexID executionVertexId)

notifySchedulingTopologyUpdated

public void notifySchedulingTopologyUpdated(SchedulingTopology schedulingTopology,
                                            List<ExecutionVertexID> newExecutionVertices)

Description copied from interface: SchedulingTopologyListener

Notifies that the scheduling topology is just updated.

Specified by:

notifySchedulingTopologyUpdated in interface SchedulingTopologyListener

Parameters:

schedulingTopology - the scheduling topology which is just updated

newExecutionVertices - the newly added execution vertices.