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

Class NotReleasingPartitionGroupReleaseStrategy

java.lang.Object

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

All Implemented Interfaces:

PartitionGroupReleaseStrategy

public class NotReleasingPartitionGroupReleaseStrategy
extends Object
implements PartitionGroupReleaseStrategy

Does not release intermediate result partitions during job execution. Relies on partitions being released at the end of the job.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NotReleasingPartitionGroupReleaseStrategy.Factory Factory for NotReleasingPartitionGroupReleaseStrategy.

Constructor Summary

Constructors

Constructor and Description
NotReleasingPartitionGroupReleaseStrategy()

Method Summary

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

NotReleasingPartitionGroupReleaseStrategy

public NotReleasingPartitionGroupReleaseStrategy()

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.