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.
SlotMatchingResolver	The interface to define the methods for request slot matching resolver.
SlotSharingResolver	The resolver to define how to construct execution slot sharing groups from the execution vertices of a job with the vertices parallelisms.

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.
SlotSharingSlotAllocator.ExecutionSlotSharingGroup	The execution slot sharing group for adaptive scheduler.
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.

Enum Summary

Enum	Description
DefaultSlotSharingResolver	The default implementation of the SlotSharingResolver.
SimpleSlotMatchingResolver	The simple slot matching resolver implementation.
SlotsBalancedSlotMatchingResolver	The slots balanced request slot matching resolver implementation.
TaskBalancedSlotSharingResolver	The implementation of the SlotSharingResolver based on tasks balanced resolver.
TasksBalancedSlotMatchingResolver	The tasks balanced request slot matching resolver implementation.