Class and Description |
---|
SlotPoolService
Service used by the
JobMaster to manage a slot pool. |
SlotPoolServiceFactory
Factory interface for
SlotPoolService . |
Class and Description |
---|
AbstractSlotPoolServiceFactory
Abstract SlotPoolServiceFactory.
|
AllocatedSlotActions
Interface for components which have to perform actions on allocated slots.
|
AllocatedSlotPool
The slot pool is responsible for maintaining a set of
AllocatedSlots . |
AllocatedSlotPool.AllocatedSlotsAndReservationStatus
A collection of
AllocatedSlots and their reservation status. |
AllocatedSlotPool.FreeSlotInfo
Information about a free slot.
|
DeclarativeSlotPool
Slot pool interface which uses Flink's declarative resource management protocol to acquire
resources.
|
DeclarativeSlotPool.NewSlotsListener
Listener interface for newly available slots.
|
DeclarativeSlotPool.NoOpNewSlotsListener
No-op
DeclarativeSlotPool.NewSlotsListener implementation. |
DeclarativeSlotPoolFactory
Factory for a
DeclarativeSlotPool . |
DeclarativeSlotPoolService
SlotPoolService implementation for the DeclarativeSlotPool . |
DeclareResourceRequirementServiceConnectionManager
ServiceConnectionManager for declaring resource requirements. |
DeclareResourceRequirementServiceConnectionManager.DeclareResourceRequirementsService
Service that accepts resource requirements.
|
LocationPreferenceSlotSelectionStrategy
This class implements a
SlotSelectionStrategy that is based on location preference hints. |
NoOpDeclareResourceRequirementServiceConnectionManager
No-op implementation of the
DeclareResourceRequirementServiceConnectionManager . |
PhysicalSlot
The context of an
AllocatedSlot . |
PhysicalSlot.Payload
Payload which can be assigned to an
AllocatedSlot . |
PhysicalSlotProvider
The provider serves physical slot requests.
|
PhysicalSlotRequest
Represents a request for a physical slot.
|
PhysicalSlotRequest.Result
Result of a
PhysicalSlotRequest . |
PhysicalSlotRequestBulk
Represents a bulk of physical slot requests.
|
PhysicalSlotRequestBulkChecker
This class tracks a fulfillability timeout of a bulk of physical slot requests.
|
PhysicalSlotRequestBulkCheckerImpl
Default implementation of
PhysicalSlotRequestBulkChecker . |
PreferredAllocationRequestSlotMatchingStrategy
RequestSlotMatchingStrategy that takes the preferred allocations into account. |
PreviousAllocationSlotSelectionStrategy
This class implements a
SlotSelectionStrategy that is based on previous allocations and
falls back to using location preference hints if there is no previous allocation. |
RequestSlotMatchingStrategy
Strategy to match slot requests to slots.
|
RequestSlotMatchingStrategy.RequestSlotMatch
Result class representing matches.
|
SimpleRequestSlotMatchingStrategy
Simple implementation of the
RequestSlotMatchingStrategy that matches the pending
requests in order as long as the resource profile can be fulfilled. |
SingleLogicalSlot
Implementation of the
LogicalSlot . |
SlotInfoWithUtilization
Container for
SlotInfo and the task executors utilization (freeSlots /
totalOfferedSlots). |
SlotPool
The Interface of a slot pool that manages slots.
|
SlotPoolService
Service used by the
JobMaster to manage a slot pool. |
SlotPoolServiceFactory
Factory interface for
SlotPoolService . |
SlotSelectionStrategy
Interface for slot selection strategies.
|
SlotSelectionStrategy.SlotInfoAndLocality |
SlotSelectionStrategy.SlotInfoAndResources
This class is a value type that combines a
SlotInfo with its remaining ResourceProfile . |
Class and Description |
---|
PhysicalSlotProvider
The provider serves physical slot requests.
|
PhysicalSlotRequestBulkChecker
This class tracks a fulfillability timeout of a bulk of physical slot requests.
|
SlotPoolService
Service used by the
JobMaster to manage a slot pool. |
Class and Description |
---|
DeclarativeSlotPool
Slot pool interface which uses Flink's declarative resource management protocol to acquire
resources.
|
SlotPoolService
Service used by the
JobMaster to manage a slot pool. |
Class and Description |
---|
PhysicalSlot
The context of an
AllocatedSlot . |
Class and Description |
---|
SlotPoolService
Service used by the
JobMaster to manage a slot pool. |
Class and Description |
---|
SlotSelectionStrategy
Interface for slot selection strategies.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.