org.apache.flink.runtime.scheduler

Interface SchedulerOperations

All Known Implementing Classes:

AdaptiveBatchScheduler, DefaultScheduler

public interface SchedulerOperations

Component which is used by SchedulingStrategy to commit scheduling decisions.

Method Summary

Modifier and Type	Method and Description
void	allocateSlotsAndDeploy(List<ExecutionVertexID> verticesToDeploy) Allocate slots and deploy the vertex when slots are returned.

Method Detail

allocateSlotsAndDeploy

void allocateSlotsAndDeploy(List<ExecutionVertexID> verticesToDeploy)

Allocate slots and deploy the vertex when slots are returned. Vertices will be deployed only after all of them have been assigned slots. The given order will be respected, i.e. tasks with smaller indices will be deployed earlier. Only vertices in CREATED state will be accepted. Errors will happen if scheduling Non-CREATED vertices.

Parameters:

verticesToDeploy - The execution vertices to deploy