Uses of Class
org.apache.flink.runtime.scheduler.adaptive.allocator.SlotSharingSlotAllocator.ExecutionSlotSharingGroup

Packages that use SlotSharingSlotAllocator.ExecutionSlotSharingGroup

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

Uses of SlotSharingSlotAllocator.ExecutionSlotSharingGroup in org.apache.flink.runtime.scheduler.adaptive.allocator

Methods in org.apache.flink.runtime.scheduler.adaptive.allocator that return types with arguments of type SlotSharingSlotAllocator.ExecutionSlotSharingGroup

Modifier and Type	Method	Description
Collection<SlotSharingSlotAllocator.ExecutionSlotSharingGroup>	DefaultSlotSharingResolver.getExecutionSlotSharingGroups(JobInformation jobInformation, VertexParallelism vertexParallelism)
Collection<SlotSharingSlotAllocator.ExecutionSlotSharingGroup>	SlotSharingResolver.getExecutionSlotSharingGroups(JobInformation jobInformation, VertexParallelism vertexParallelism)	Get the execution slot sharing groups for the job information based on the vertices parallelisms.
List<SlotSharingSlotAllocator.ExecutionSlotSharingGroup>	TaskBalancedSlotSharingResolver.getExecutionSlotSharingGroups(JobInformation jobInformation, VertexParallelism vertexParallelism)

Methods in org.apache.flink.runtime.scheduler.adaptive.allocator with parameters of type SlotSharingSlotAllocator.ExecutionSlotSharingGroup

Modifier and Type	Method	Description
Collection<org.apache.flink.runtime.scheduler.adaptive.allocator.StateLocalitySlotAssigner.AllocationScore>	StateLocalitySlotAssigner.calculateScore(SlotSharingSlotAllocator.ExecutionSlotSharingGroup group, Map<JobVertexID,Integer> parallelism, JobInformation jobInformation, JobAllocationsInformation previousAllocations)

Method parameters in org.apache.flink.runtime.scheduler.adaptive.allocator with type arguments of type SlotSharingSlotAllocator.ExecutionSlotSharingGroup

Modifier and Type	Method	Description
Collection<JobSchedulingPlan.SlotAssignment>	SimpleSlotMatchingResolver.matchSlotSharingGroupWithSlots(Collection<SlotSharingSlotAllocator.ExecutionSlotSharingGroup> requestGroups, Collection<PhysicalSlot> freeSlots)
Collection<JobSchedulingPlan.SlotAssignment>	SlotMatchingResolver.matchSlotSharingGroupWithSlots(Collection<SlotSharingSlotAllocator.ExecutionSlotSharingGroup> requestGroups, Collection<PhysicalSlot> freeSlots)	Match slots from the free slots with the given collection of requests execution groups.
Collection<JobSchedulingPlan.SlotAssignment>	SlotsBalancedSlotMatchingResolver.matchSlotSharingGroupWithSlots(Collection<SlotSharingSlotAllocator.ExecutionSlotSharingGroup> requestGroups, Collection<PhysicalSlot> freeSlots)
Collection<JobSchedulingPlan.SlotAssignment>	TasksBalancedSlotMatchingResolver.matchSlotSharingGroupWithSlots(Collection<SlotSharingSlotAllocator.ExecutionSlotSharingGroup> requestGroups, Collection<PhysicalSlot> freeSlots)