Package | Description |
---|---|
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.jobmaster.slotpool | |
org.apache.flink.runtime.scheduler.adaptive.allocator |
Modifier and Type | Interface and Description |
---|---|
interface |
SlotContext
Interface for the context of a
LogicalSlot . |
Modifier and Type | Interface and Description |
---|---|
interface |
PhysicalSlot
The context of an
AllocatedSlot . |
Modifier and Type | Class and Description |
---|---|
class |
SlotInfoWithUtilization
Container for
SlotInfo and the task executors utilization (freeSlots /
totalOfferedSlots). |
Modifier and Type | Method and Description |
---|---|
SlotInfo |
SlotSelectionStrategy.SlotInfoAndResources.getSlotInfo() |
SlotInfo |
SlotSelectionStrategy.SlotInfoAndLocality.getSlotInfo() |
Modifier and Type | Method and Description |
---|---|
Collection<SlotInfo> |
SlotPool.getAllocatedSlotsInformation()
Returns a list of
SlotInfo objects about all slots that are currently allocated in
the slot pool. |
Collection<SlotInfo> |
DeclarativeSlotPoolBridge.getAllocatedSlotsInformation() |
Collection<? extends SlotInfo> |
AllocatedSlotPool.getAllSlotsInformation()
Returns information about all slots in this pool.
|
Collection<? extends SlotInfo> |
DefaultDeclarativeSlotPool.getAllSlotsInformation() |
Collection<? extends SlotInfo> |
DefaultAllocatedSlotPool.getAllSlotsInformation() |
Collection<? extends SlotInfo> |
DeclarativeSlotPool.getAllSlotsInformation()
Returns the slot information for all slots (free and allocated slots).
|
Optional<SlotInfo> |
AllocatedSlotPool.getSlotInformation(AllocationID allocationID)
Returns slot information specified by the given allocationId.
|
Optional<SlotInfo> |
DefaultAllocatedSlotPool.getSlotInformation(AllocationID allocationID) |
Modifier and Type | Method and Description |
---|---|
static SlotInfoWithUtilization |
SlotInfoWithUtilization.from(SlotInfo slotInfo,
double taskExecutorUtilization) |
static SlotSelectionStrategy.SlotInfoAndLocality |
SlotSelectionStrategy.SlotInfoAndLocality.of(SlotInfo slotInfo,
Locality locality) |
Constructor and Description |
---|
SlotInfoAndResources(SlotInfo slotInfo,
ResourceProfile remainingResources,
double taskExecutorUtilization) |
Modifier and Type | Method and Description |
---|---|
Optional<? extends VertexParallelism> |
SlotAllocator.determineParallelism(JobInformation jobInformation,
Collection<? extends SlotInfo> slots)
Determines the parallelism at which the vertices could be scheduled given the collection of
slots.
|
Optional<VertexParallelismWithSlotSharing> |
SlotSharingSlotAllocator.determineParallelism(JobInformation jobInformation,
Collection<? extends SlotInfo> freeSlots) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.