Package org.apache.flink.runtime.jobmanager.scheduler

Interface Summary

Interface	Description
SlotAvailabilityListener	A SlotAvailabilityListener can be notified when new Slots become available on an Instance.

Class Summary

Class	Description
CoLocationConstraint	A CoLocationConstraint manages the location of a set of tasks (Execution Vertices).
CoLocationGroup	A Co-location group is a group of JobVertices, where the i-th subtask of one vertex has to be executed on the same TaskManager as the i-th subtask of all other JobVertices in the same group.
LifoSetQueue<E>	A queue that returns elements in LIFO order and simultaneously maintains set characteristics, i.e., elements that are already in the queue may not be added another time.
ScheduledUnit
Scheduler	The scheduler is responsible for distributing the ready-to-run tasks among instances and slots.
SetQueue<E>	A queue that maintains set characteristics, i.e., elements that are already in the queue may not be added another time.
SlotSharingGroup	A slot sharing units defines which different task (from different job vertices) can be deployed together within a slot.

Enum Summary

Enum	Description
Locality
LocationPreferenceConstraint	Defines the location preference constraint.

Exception Summary

Exception	Description
NoResourceAvailableException