Package | Description |
---|---|
org.apache.flink.runtime.resourcemanager.slotmanager |
Modifier and Type | Class and Description |
---|---|
class |
TaskManagerSlot
A TaskManagerSlot represents a slot located in a TaskManager.
|
Modifier and Type | Method and Description |
---|---|
<T extends TaskManagerSlotInformation> |
LeastUtilizationSlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup) |
<T extends TaskManagerSlotInformation> |
SlotMatchingStrategy.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> |
AnyMatchingSlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.