org.apache.flink.runtime.scheduler

Class SimpleExecutionSlotAllocator

java.lang.Object

org.apache.flink.runtime.scheduler.SimpleExecutionSlotAllocator

All Implemented Interfaces:

ExecutionSlotAllocator

public class SimpleExecutionSlotAllocator
extends Object
implements ExecutionSlotAllocator

A simple implementation of ExecutionSlotAllocator. No support for slot sharing, co-location, state/input locality, nor local recovery.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SimpleExecutionSlotAllocator.Factory Factory to instantiate a SimpleExecutionSlotAllocator.

Method Summary

Modifier and Type	Method and Description
List<org.apache.flink.runtime.scheduler.ExecutionSlotAssignment>	allocateSlotsFor(List<ExecutionAttemptID> executionAttemptIds) Allocate slots for the given executions.
void	cancel(ExecutionAttemptID executionAttemptId) Cancel the ongoing slot request of the given Execution.

Methods inherited from class java.lang.Object

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

Method Detail

allocateSlotsFor

public List<org.apache.flink.runtime.scheduler.ExecutionSlotAssignment> allocateSlotsFor(List<ExecutionAttemptID> executionAttemptIds)

Description copied from interface: ExecutionSlotAllocator

Allocate slots for the given executions.

Specified by:

allocateSlotsFor in interface ExecutionSlotAllocator

Parameters:

executionAttemptIds - executions to allocate slots for

Returns:

List of slot assignments to the executions

cancel

public void cancel(ExecutionAttemptID executionAttemptId)

Description copied from interface: ExecutionSlotAllocator

Cancel the ongoing slot request of the given Execution.

Specified by:

cancel in interface ExecutionSlotAllocator

Parameters:

executionAttemptId - identifying the Execution of which the slot request should be canceled.