public interface SlotMatchingStrategy
Modifier and Type | Method and Description |
---|---|
<T extends TaskManagerSlotInformation> |
findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup)
Finds a matching slot for the requested
ResourceProfile given the collection of free
slots and the total number of slots per TaskExecutor. |
<T extends TaskManagerSlotInformation> Optional<T> findMatchingSlot(ResourceProfile requestedProfile, Collection<T> freeSlots, java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup)
ResourceProfile
given the collection of free
slots and the total number of slots per TaskExecutor.requestedProfile
- to find a matching slot forfreeSlots
- collection of free slotsnumberRegisteredSlotsLookup
- lookup for the number of registered slotsOptional.empty()
if there is noneCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.