Package org.apache.flink.runtime.scheduler.adaptive.allocator

Interface Summary

Interface	Description
FreeSlotFunction	A function for freeing slots.
IsSlotAvailableAndFreeFunction	Functional interface for checking whether a slot is available and free.
JobInformation	Information about the job.
JobInformation.VertexInformation	Information about a single vertex.
ReserveSlotFunction	A function for reserving slots.
SlotAllocator	Component for calculating the slot requirements and mapping of vertices to slots.
SlotAssigner	Interface for assigning slots to slot sharing groups.

Class Summary

Class	Description
DefaultSlotAssigner	Simple SlotAssigner that treats all slots and slot sharing groups equally.
JobAllocationsInformation	Information about allocations of Job Vertices.
JobAllocationsInformation.VertexAllocationInformation	Information about the allocations of a single Job Vertex.
ReservedSlots	Container for the set of reserved slots for ExecutionVertexID.
SlotSharingSlotAllocator	SlotAllocator implementation that supports slot sharing.
StateLocalitySlotAssigner	A SlotAssigner that assigns slots based on the number of local key groups.
StateSizeEstimates	Managed Keyed State size estimates used to make scheduling decisions.
VertexParallelism	Core result of SlotAllocator.determineParallelism(JobInformation, Collection) among with slotAssignments, describing the parallelism each vertex could be scheduled with.