public class PipelinedRegionSchedulingStrategy extends Object implements SchedulingStrategy
SchedulingStrategy
instance which schedules tasks in granularity of pipelined regions.Modifier and Type | Class and Description |
---|---|
static class |
PipelinedRegionSchedulingStrategy.Factory
The factory for creating
PipelinedRegionSchedulingStrategy . |
Constructor and Description |
---|
PipelinedRegionSchedulingStrategy(SchedulerOperations schedulerOperations,
SchedulingTopology schedulingTopology) |
Modifier and Type | Method and Description |
---|---|
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).
|
public PipelinedRegionSchedulingStrategy(SchedulerOperations schedulerOperations, SchedulingTopology schedulingTopology)
public void startScheduling()
SchedulingStrategy
startScheduling
in interface SchedulingStrategy
public void restartTasks(Set<ExecutionVertexID> verticesToRestart)
SchedulingStrategy
restartTasks
in interface SchedulingStrategy
verticesToRestart
- The tasks need to be restartedpublic void onExecutionStateChange(ExecutionVertexID executionVertexId, ExecutionState executionState)
SchedulingStrategy
Execution
changes its state.onExecutionStateChange
in interface SchedulingStrategy
executionVertexId
- The id of the taskexecutionState
- The new state of the executionpublic void onPartitionConsumable(IntermediateResultPartitionID resultPartitionId)
SchedulingStrategy
IntermediateResultPartition
becomes consumable.onPartitionConsumable
in interface SchedulingStrategy
resultPartitionId
- The id of the result partitionCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.