Uses of Package
org.apache.flink.runtime.scheduler.adaptive.allocator
-
Classes in org.apache.flink.runtime.scheduler.adaptive.allocator used by org.apache.flink.runtime.jobgraph.jsonplan Class Description VertexParallelism Core result ofSlotAllocator.determineParallelism(JobInformation, Collection)among withslotAssignments, describing the parallelism each vertex could be scheduled with. -
Classes in org.apache.flink.runtime.scheduler.adaptive.allocator used by org.apache.flink.runtime.scheduler.adaptive Class Description JobInformation Information about the job.JobInformation.VertexInformation Information about a single vertex.SlotAllocator Component for calculating the slot requirements and mapping of vertices to slots.SlotSharingSlotAllocator SlotAllocatorimplementation that supports slot sharing.VertexParallelism Core result ofSlotAllocator.determineParallelism(JobInformation, Collection)among withslotAssignments, describing the parallelism each vertex could be scheduled with. -
Classes in org.apache.flink.runtime.scheduler.adaptive.allocator used by org.apache.flink.runtime.scheduler.adaptive.allocator Class Description DefaultSlotSharingResolver The default implementation of theSlotSharingResolver.FreeSlotFunction A function for freeing slots.IsSlotAvailableAndFreeFunction Functional interface for checking whether a slot is available and free.JobAllocationsInformation Information about allocations of Job Vertices.JobAllocationsInformation.VertexAllocationInformation Information about the allocations of a single Job Vertex.JobInformation Information about the job.JobInformation.VertexInformation Information about a single vertex.ReservedSlots Container for the set of reserved slots forExecutionVertexID.ReserveSlotFunction A function for reserving slots.SimpleSlotMatchingResolver The simple slot matching resolver implementation.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.SlotsBalancedSlotMatchingResolver The slots balanced request slot matching resolver implementation.SlotSharingResolver The resolver to define how to construct execution slot sharing groups from the execution vertices of a job with the vertices parallelisms.SlotSharingSlotAllocator SlotAllocatorimplementation that supports slot sharing.SlotSharingSlotAllocator.ExecutionSlotSharingGroup The execution slot sharing group for adaptive scheduler.StateSizeEstimates Managed Keyed State size estimates used to make scheduling decisions.TaskBalancedSlotSharingResolver The implementation of theSlotSharingResolverbased on tasks balanced resolver.TasksBalancedSlotMatchingResolver The tasks balanced request slot matching resolver implementation.VertexParallelism Core result ofSlotAllocator.determineParallelism(JobInformation, Collection)among withslotAssignments, describing the parallelism each vertex could be scheduled with.