Package | Description |
---|---|
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.jobmaster.slotpool |
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> |
SlotPoolImpl.getAllocatedSlotsInformation() |
Collection<? extends SlotInfo> |
DefaultAllocatedSlotPool.getAllSlotsInformation() |
Collection<? extends SlotInfo> |
AllocatedSlotPool.getAllSlotsInformation()
Returns information about all slots in this pool.
|
Modifier and Type | Method and Description |
---|---|
static SlotInfoWithUtilization |
SlotInfoWithUtilization.from(SlotInfo slotInfo,
double taskExecutorUtilization) |
SlotSharingManager.MultiTaskSlot |
SlotSharingManager.getResolvedRootSlot(SlotInfo slotInfo) |
static SlotSelectionStrategy.SlotInfoAndLocality |
SlotSelectionStrategy.SlotInfoAndLocality.of(SlotInfo slotInfo,
Locality locality) |
Constructor and Description |
---|
SlotInfoAndResources(SlotInfo slotInfo,
ResourceProfile remainingResources,
double taskExecutorUtilization) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.