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.FreeSlotInfo |
Information about a free slot.
|
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.
|
Scheduler |
Basic interface for the current scheduler, which is a
SlotProvider and a SlotOwner . |
SlotPool |
The Interface of a slot pool that manages slots.
|
SlotPoolFactory |
Factory interface for
SlotPool . |
SlotProvider |
The slot provider is responsible for preparing slots for ready-to-run tasks.
|
SlotSelectionStrategy |
Interface for slot selection strategies to be used in the
Scheduler . |
Class | Description |
---|---|
AbstractServiceConnectionManager<S> |
Base class for service connection managers, taking care of the connection handling.
|
AbstractSlotPoolFactory |
Abstract SlotPoolFactory.
|
DefaultAllocatedSlotPool |
Default
AllocatedSlotPool implementation. |
DefaultSlotPoolFactory |
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. |
SchedulerImpl |
Scheduler that assigns tasks to slots.
|
SingleLogicalSlot |
Implementation of the
LogicalSlot which is used by the SlotPoolImpl . |
SlotAndLocality |
A combination of a
AllocatedSlot and a Locality . |
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 . |
SlotSharingManager |
Manager which is responsible for slot sharing.
|
SlotSharingManager.TaskSlot |
Base class for all task slots.
|
ThrowingSlotProvider |
A slot provider that validates that it is not in use by throwing
IllegalStateException on
any method call. |
Enum | Description |
---|---|
NoOpDeclareResourceRequirementServiceConnectionManager |
No-op implementation of the
DeclareResourceRequirementServiceConnectionManager . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.