public interface PhysicalSlotProvider
|Modifier and Type||Method and Description|
Submit requests to allocate physical slots.
Cancels the slot request with the given
Disables batch slot request timeout check.
Map<SlotRequestId,CompletableFuture<PhysicalSlotRequest.Result>> allocatePhysicalSlots(Collection<PhysicalSlotRequest> physicalSlotRequests)
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.
physicalSlotRequests- physicalSlotRequest slot requirements
void cancelSlotRequest(SlotRequestId slotRequestId, Throwable cause)
If the request is already fulfilled with a physical slot, the slot will be released.
slotRequestId- identifying the slot request to cancel
cause- of the cancellation
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.