Package | Description |
---|---|
org.apache.flink.runtime.resourcemanager.slotmanager |
Modifier and Type | Class and Description |
---|---|
class |
FineGrainedTaskManagerSlot
A FineGrainedTaskManagerSlot represents a slot located in a TaskManager.
|
Modifier and Type | Method and Description |
---|---|
<T extends TaskManagerSlotInformation> |
AnyMatchingSlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup) |
<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. |
Modifier and Type | Method and Description |
---|---|
Optional<TaskManagerSlotInformation> |
FineGrainedTaskManagerTracker.getAllocatedOrPendingSlot(AllocationID allocationId) |
Map<AllocationID,TaskManagerSlotInformation> |
TaskManagerInfo.getAllocatedSlots()
Get allocated slots information.
|
Map<AllocationID,TaskManagerSlotInformation> |
FineGrainedTaskManagerRegistration.getAllocatedSlots() |
Collection<TaskManagerSlotInformation> |
DefaultSlotTracker.getFreeSlots() |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.