| 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 |
|
| DeclarativeSlotPool.NoOpResourceRequestStableListener |
|
| DeclarativeSlotPool.ResourceRequestStableListener |
Listener interface for no more resource requests in the JobManagerOptions.SLOT_REQUEST_MAX_INTERVAL.
|
| DeclarativeSlotPoolFactory |
|
| DeclarativeSlotPoolService |
|
| DeclareResourceRequirementServiceConnectionManager |
|
| DeclareResourceRequirementServiceConnectionManager.DeclareResourceRequirementsService |
Service that accepts resource requirements.
|
| DefaultDeclarativeSlotPool |
|
| DefaultFreeSlotTracker |
|
| FreeSlotTracker |
Track all free slots.
|
| LocationPreferenceSlotSelectionStrategy |
|
| NoOpDeclareResourceRequirementServiceConnectionManager |
|
| 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 |
|
| PhysicalSlotRequestBulk |
Represents a bulk of physical slot requests.
|
| PhysicalSlotRequestBulkChecker |
This class tracks a fulfillability timeout of a bulk of physical slot requests.
|
| PhysicalSlotRequestBulkCheckerImpl |
|
| 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 |
|
| SlotPool |
The Interface of a slot pool that manages slots.
|
| SlotPoolService |
Service used by the JobMaster to manage a slot pool.
|
| SlotPoolServiceFactory |
|
| SlotSelectionStrategy |
Interface for slot selection strategies.
|
| SlotSelectionStrategy.NoOpSlotSelectionStrategy |
|
| SlotSelectionStrategy.SlotInfoAndLocality |
|
| TasksBalancedRequestSlotMatchingStrategy |
The tasks balanced based implementation of RequestSlotMatchingStrategy that matches the
pending requests for tasks balance at task-manager level.
|