org.apache.flink.runtime.scheduler.strategy

Class VertexwiseSchedulingStrategy

java.lang.Object

org.apache.flink.runtime.scheduler.strategy.VertexwiseSchedulingStrategy

All Implemented Interfaces:

SchedulingTopologyListener, SchedulingStrategy

public class VertexwiseSchedulingStrategy
extends Object
implements SchedulingStrategy, SchedulingTopologyListener

SchedulingStrategy instance which schedules tasks in granularity of vertex (which indicates this strategy only supports batch jobs). Note that this strategy implements SchedulingTopologyListener, so it can handle the updates of scheduling topology.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	VertexwiseSchedulingStrategy.Factory The factory for creating VertexwiseSchedulingStrategy.

Constructor Summary

Constructors

Constructor and Description
VertexwiseSchedulingStrategy(SchedulerOperations schedulerOperations, SchedulingTopology schedulingTopology, InputConsumableDecider.Factory inputConsumableDeciderFactory)

Method Summary

Modifier and Type	Method and Description
void	notifySchedulingTopologyUpdated(SchedulingTopology schedulingTopology, List<ExecutionVertexID> newExecutionVertices) Notifies that the scheduling topology is just updated.
void	onExecutionStateChange(ExecutionVertexID executionVertexId, ExecutionState executionState) Called whenever an Execution changes its state.
void	onPartitionConsumable(IntermediateResultPartitionID resultPartitionId) Called whenever an IntermediateResultPartition becomes consumable.
void	restartTasks(Set<ExecutionVertexID> verticesToRestart) Called whenever vertices need to be restarted (due to task failure).
void	startScheduling() Called when the scheduling is started (initial scheduling operation).

Methods inherited from class java.lang.Object

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

Constructor Detail

VertexwiseSchedulingStrategy

public VertexwiseSchedulingStrategy(SchedulerOperations schedulerOperations,
                                    SchedulingTopology schedulingTopology,
                                    InputConsumableDecider.Factory inputConsumableDeciderFactory)

Method Detail

startScheduling

public void startScheduling()

Description copied from interface: SchedulingStrategy

Called when the scheduling is started (initial scheduling operation).

Specified by:

startScheduling in interface SchedulingStrategy

restartTasks

public void restartTasks(Set<ExecutionVertexID> verticesToRestart)

Description copied from interface: SchedulingStrategy

Called whenever vertices need to be restarted (due to task failure).

Specified by:

restartTasks in interface SchedulingStrategy

Parameters:

verticesToRestart - The tasks need to be restarted

onExecutionStateChange

public void onExecutionStateChange(ExecutionVertexID executionVertexId,
                                   ExecutionState executionState)

Description copied from interface: SchedulingStrategy

Called whenever an Execution changes its state.

Specified by:

onExecutionStateChange in interface SchedulingStrategy

Parameters:

executionVertexId - The id of the task

executionState - The new state of the execution

onPartitionConsumable

public void onPartitionConsumable(IntermediateResultPartitionID resultPartitionId)

Description copied from interface: SchedulingStrategy

Called whenever an IntermediateResultPartition becomes consumable.

Specified by:

onPartitionConsumable in interface SchedulingStrategy

Parameters:

resultPartitionId - The id of the result partition

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.