Package | Description |
---|---|
org.apache.flink.runtime.clusterframework.types | |
org.apache.flink.runtime.jobmaster.slotpool |
Modifier and Type | Method and Description |
---|---|
static SlotProfile |
SlotProfile.priorAllocation(ResourceProfile taskResourceProfile,
ResourceProfile physicalSlotResourceProfile,
Collection<TaskManagerLocation> preferredLocations,
Collection<AllocationID> priorAllocations,
Set<AllocationID> reservedAllocations)
Returns a slot profile for the given resource profile, prior allocations and all prior
allocation ids from the whole execution graph.
|
Modifier and Type | Method and Description |
---|---|
SlotProfile |
PhysicalSlotRequest.getSlotProfile() |
Modifier and Type | Method and Description |
---|---|
Optional<SlotSelectionStrategy.SlotInfoAndLocality> |
LocationPreferenceSlotSelectionStrategy.selectBestSlotForProfile(Collection<SlotSelectionStrategy.SlotInfoAndResources> availableSlots,
SlotProfile slotProfile) |
Optional<SlotSelectionStrategy.SlotInfoAndLocality> |
PreviousAllocationSlotSelectionStrategy.selectBestSlotForProfile(Collection<SlotSelectionStrategy.SlotInfoAndResources> availableSlots,
SlotProfile slotProfile) |
Optional<SlotSelectionStrategy.SlotInfoAndLocality> |
SlotSelectionStrategy.selectBestSlotForProfile(Collection<SlotSelectionStrategy.SlotInfoAndResources> availableSlots,
SlotProfile slotProfile)
Selects the best
SlotInfo w.r.t. |
Constructor and Description |
---|
PhysicalSlotRequest(SlotRequestId slotRequestId,
SlotProfile slotProfile,
boolean slotWillBeOccupiedIndefinitely) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.