Package org.apache.flink.runtime.jobmaster.slotpool

Interface Summary

Interface	Description
AllocatedSlotActions	Interface for components which have to perform actions on allocated slots.
PhysicalSlot	The context of an AllocatedSlot.
PhysicalSlot.Payload	Payload which can be assigned to an AllocatedSlot.
Scheduler	Basic interface for the current scheduler, which is a SlotProvider and a SlotOwner.
SchedulerFactory	Factory interface for Scheduler.
SlotPool	The Interface of a slot pool that manages slots.
SlotPoolFactory	Factory interface for SlotPool.
SlotProvider	The slot provider is responsible for preparing slots for ready-to-run tasks.
SlotSelectionStrategy	Interface for slot selection strategies to be used in the Scheduler.

Class Summary

Class	Description
DefaultSchedulerFactory	Default implementation of a SchedulerFactory.
DefaultSlotPoolFactory	Default slot pool factory.
DualKeyMap<A,B,V>	Map which stores values under two different indices.
SchedulerImpl	Scheduler that assigns tasks to slots.
SingleLogicalSlot	Implementation of the LogicalSlot which is used by the SlotPoolImpl.
SlotAndLocality	A combination of a AllocatedSlot and a Locality.
SlotPoolImpl	The slot pool serves slot request issued by ExecutionGraph.
SlotPoolImpl.AvailableSlots	Organize all available slots from different points of view.
SlotSelectionStrategy.SlotInfoAndLocality	This class is a value type that combines a SlotInfo with a Locality hint.
SlotSharingManager	Manager which is responsible for slot sharing.
SlotSharingManager.TaskSlot	Base class for all task slots.

Enum Summary

Enum	Description
LocationPreferenceSlotSelectionStrategy	This class implements a SlotSelectionStrategy that is based on location preference hints.
PreviousAllocationSlotSelectionStrategy	This class implements a SlotSelectionStrategy that is based on previous allocations and falls back to using location preference hints if there is no previous allocation.