public class PhysicalSlotProviderImpl extends Object implements PhysicalSlotProvider
Constructor and Description |
---|
PhysicalSlotProviderImpl(SlotSelectionStrategy slotSelectionStrategy,
SlotPool slotPool) |
Modifier and Type | Method and Description |
---|---|
Map<SlotRequestId,CompletableFuture<PhysicalSlotRequest.Result>> |
allocatePhysicalSlots(Collection<PhysicalSlotRequest> physicalSlotRequests)
Submit requests to allocate physical slots.
|
void |
cancelSlotRequest(SlotRequestId slotRequestId,
Throwable cause)
Cancels the slot request with the given
SlotRequestId . |
void |
disableBatchSlotRequestTimeoutCheck()
Disables batch slot request timeout check.
|
public PhysicalSlotProviderImpl(SlotSelectionStrategy slotSelectionStrategy, SlotPool slotPool)
public void disableBatchSlotRequestTimeoutCheck()
PhysicalSlotProvider
disableBatchSlotRequestTimeoutCheck
in interface PhysicalSlotProvider
public Map<SlotRequestId,CompletableFuture<PhysicalSlotRequest.Result>> allocatePhysicalSlots(Collection<PhysicalSlotRequest> physicalSlotRequests)
PhysicalSlotProvider
The physical slot can be either allocated from the slots, which are already available for the job, or a new one can be requested from the resource manager.
allocatePhysicalSlots
in interface PhysicalSlotProvider
physicalSlotRequests
- physicalSlotRequest slot requirementspublic void cancelSlotRequest(SlotRequestId slotRequestId, Throwable cause)
PhysicalSlotProvider
SlotRequestId
.
If the request is already fulfilled with a physical slot, the slot will be released.
cancelSlotRequest
in interface PhysicalSlotProvider
slotRequestId
- identifying the slot request to cancelcause
- of the cancellationCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.