Interface SlotMatchingResolver
-
- All Known Implementing Classes:
SimpleSlotMatchingResolver,SlotsBalancedSlotMatchingResolver,TasksBalancedSlotMatchingResolver
public interface SlotMatchingResolverThe interface to define the methods for request slot matching resolver.
-
-
Field Summary
Fields Modifier and Type Field Description static Supplier<org.apache.flink.util.FlinkRuntimeException>NO_SLOTS_EXCEPTION_GETTER
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Collection<JobSchedulingPlan.SlotAssignment>matchSlotSharingGroupWithSlots(Collection<SlotSharingSlotAllocator.ExecutionSlotSharingGroup> requestGroups, Collection<PhysicalSlot> freeSlots)Match slots from the free slots with the given collection of requests execution groups.
-
-
-
Field Detail
-
NO_SLOTS_EXCEPTION_GETTER
static final Supplier<org.apache.flink.util.FlinkRuntimeException> NO_SLOTS_EXCEPTION_GETTER
-
-
Method Detail
-
matchSlotSharingGroupWithSlots
Collection<JobSchedulingPlan.SlotAssignment> matchSlotSharingGroupWithSlots(Collection<SlotSharingSlotAllocator.ExecutionSlotSharingGroup> requestGroups, Collection<PhysicalSlot> freeSlots)
Match slots from the free slots with the given collection of requests execution groups.- Parameters:
requestGroups- the requested execution slot sharing groups.freeSlots- the free slots.- Returns:
- The assignment result.
-
-