public interface PhysicalSlotProvider
|Modifier and Type||Method and Description|
Submit a request to allocate a physical slot.
Cancels the slot request with the given
Disables batch slot request timeout check.
CompletableFuture<PhysicalSlotRequest.Result> allocatePhysicalSlot(PhysicalSlotRequest physicalSlotRequest)
The physical slot can be either allocated from the slots, which are already available for the job, or a new one can be requeted from the resource manager.
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–2022 The Apache Software Foundation. All rights reserved.