org.apache.flink.runtime.scheduler

Interface ExecutionDeployer

All Known Implementing Classes:

DefaultExecutionDeployer

public interface ExecutionDeployer

This deployer is responsible for deploying executions.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ExecutionDeployer.Factory Factory to instantiate the ExecutionDeployer.

Method Summary

Modifier and Type	Method and Description
void	allocateSlotsAndDeploy(List<Execution> executionsToDeploy, Map<ExecutionVertexID,ExecutionVertexVersion> requiredVersionByVertex) Allocate slots and deploy executions.

Method Detail

allocateSlotsAndDeploy

void allocateSlotsAndDeploy(List<Execution> executionsToDeploy,
                            Map<ExecutionVertexID,ExecutionVertexVersion> requiredVersionByVertex)

Allocate slots and deploy executions.

Parameters:

executionsToDeploy - executions to deploy

requiredVersionByVertex - required versions of the execution vertices. If the actual version does not match, the deployment of the execution will be rejected.