org.apache.flink.runtime.resourcemanager.slotmanager

Interface SlotMatchingStrategy

All Known Implementing Classes:

AnyMatchingSlotMatchingStrategy, LeastUtilizationSlotMatchingStrategy

public interface SlotMatchingStrategy

Strategy how to find a matching slot.

Method Summary

Modifier and Type	Method and Description
<T extends TaskManagerSlotInformation> Optional<T>	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.

Method Detail

findMatchingSlot

<T extends TaskManagerSlotInformation> Optional<T> 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.

Parameters:

requestedProfile - to find a matching slot for

freeSlots - collection of free slots

numberRegisteredSlotsLookup - lookup for the number of registered slots

Returns:

Returns a matching slots or Optional.empty() if there is none