Interface | Description |
---|---|
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.
|
DeclarativeSlotPoolFactory |
Factory for a
DeclarativeSlotPool . |
DeclareResourceRequirementServiceConnectionManager |
ServiceConnectionManager for declaring resource requirements. |
DeclareResourceRequirementServiceConnectionManager.DeclareResourceRequirementsService |
Service that accepts resource requirements.
|
PhysicalSlot |
The context of an
AllocatedSlot . |
PhysicalSlot.Payload |
Payload which can be assigned to an
AllocatedSlot . |
PhysicalSlotProvider |
The provider serves physical slot requests.
|
PhysicalSlotRequestBulk |
Represents a bulk of physical slot requests.
|
PhysicalSlotRequestBulkChecker |
This class tracks a fulfillability timeout of a bulk of physical slot requests.
|
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.
|
Class | Description |
---|---|
AbstractServiceConnectionManager<S> |
Base class for service connection managers, taking care of the connection handling.
|
AbstractSlotPoolServiceFactory |
Abstract SlotPoolServiceFactory.
|
DeclarativeSlotPoolBridge |
SlotPool implementation which uses the DeclarativeSlotPool to allocate slots. |
DeclarativeSlotPoolBridgeServiceFactory |
Factory for
DeclarativeSlotPoolBridge . |
DeclarativeSlotPoolService |
SlotPoolService implementation for the DeclarativeSlotPool . |
DeclarativeSlotPoolServiceFactory |
Factory for the
DeclarativeSlotPoolService . |
DefaultAllocatedSlotPool |
Default
AllocatedSlotPool implementation. |
DefaultDeclarativeSlotPool |
Default
DeclarativeSlotPool implementation. |
DefaultDeclarativeSlotPoolFactory |
Factory for
DefaultDeclarativeSlotPool . |
DefaultSlotPoolServiceFactory |
Default slot pool factory.
|
LocationPreferenceSlotSelectionStrategy |
This class implements a
SlotSelectionStrategy that is based on location preference hints. |
PhysicalSlotProviderImpl |
The provider serves physical slot requests.
|
PhysicalSlotRequest |
Represents a request for a physical slot.
|
PhysicalSlotRequest.Result |
Result of a
PhysicalSlotRequest . |
PhysicalSlotRequestBulkCheckerImpl |
Default implementation of
PhysicalSlotRequestBulkChecker . |
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. |
SingleLogicalSlot |
Implementation of the
LogicalSlot which is used by the SlotPoolImpl . |
SlotInfoWithUtilization |
Container for
SlotInfo and the task executors utilization (freeSlots /
totalOfferedSlots). |
SlotPoolImpl |
The slot pool serves slot request issued by
ExecutionGraph . |
SlotPoolImpl.AvailableSlots |
Organize all available slots from different points of view.
|
SlotPoolImpl.PendingRequest |
A pending request for a slot.
|
SlotSelectionStrategy.SlotInfoAndLocality | |
SlotSelectionStrategy.SlotInfoAndResources |
This class is a value type that combines a
SlotInfo with its remaining ResourceProfile . |
Enum | Description |
---|---|
DeclarativeSlotPool.NoOpNewSlotsListener |
No-op
DeclarativeSlotPool.NewSlotsListener implementation. |
NoOpDeclareResourceRequirementServiceConnectionManager |
No-op implementation of the
DeclareResourceRequirementServiceConnectionManager . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.