Package | Description |
---|---|
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.jobmaster.slotpool |
Modifier and Type | Class and Description |
---|---|
class |
SimpleSlotContext
Simple implementation of the
SlotContext interface for the legacy code. |
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 | Method and Description |
---|---|
SlotInfo |
SlotSelectionStrategy.SlotInfoAndLocality.getSlotInfo() |
Modifier and Type | Method and Description |
---|---|
Collection<SlotInfo> |
SlotPoolImpl.getAvailableSlotsInformation() |
Collection<SlotInfo> |
SlotPool.getAvailableSlotsInformation()
Returns a list of
SlotInfo objects about all slots that are currently available in the slot
pool. |
Collection<SlotInfo> |
SlotSharingManager.listResolvedRootSlotInfo(AbstractID groupId) |
Modifier and Type | Method and Description |
---|---|
SlotSharingManager.MultiTaskSlot |
SlotSharingManager.getResolvedRootSlot(SlotInfo slotInfo) |
static SlotSelectionStrategy.SlotInfoAndLocality |
SlotSelectionStrategy.SlotInfoAndLocality.of(SlotInfo slotInfo,
Locality locality) |
Modifier and Type | Method and Description |
---|---|
Optional<SlotSelectionStrategy.SlotInfoAndLocality> |
PreviousAllocationSlotSelectionStrategy.selectBestSlotForProfile(Collection<? extends SlotInfo> availableSlots,
SlotProfile slotProfile) |
Optional<SlotSelectionStrategy.SlotInfoAndLocality> |
LocationPreferenceSlotSelectionStrategy.selectBestSlotForProfile(Collection<? extends SlotInfo> availableSlots,
SlotProfile slotProfile) |
Optional<SlotSelectionStrategy.SlotInfoAndLocality> |
SlotSelectionStrategy.selectBestSlotForProfile(Collection<? extends SlotInfo> availableSlots,
SlotProfile slotProfile)
Selects the best
SlotInfo w.r.t. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.