Modifier and Type | Method and Description |
---|---|
abstract CompletableFuture<LogicalSlot> |
SlotProviderStrategy.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile)
Allocating slot with specific requirement.
|
void |
SlotProviderStrategy.cancelSlotRequest(SlotRequestId slotRequestId,
SlotSharingGroupId slotSharingGroupId,
Throwable cause)
Cancels the slot request with the given
SlotRequestId and SlotSharingGroupId . |
Modifier and Type | Method and Description |
---|---|
SlotRequestId |
CoLocationConstraint.getSlotRequestId()
Returns the currently assigned slot request id identifying the slot to which tasks belonging
to this co-location constraint will be deployed to.
|
Modifier and Type | Method and Description |
---|---|
void |
CoLocationConstraint.setSlotRequestId(SlotRequestId slotRequestId)
Sets the slot request id of the currently assigned slot to the co-location constraint.
|
Modifier and Type | Method and Description |
---|---|
SlotRequestId |
LogicalSlot.getSlotRequestId()
Gets the slot request id uniquely identifying the request with which this slot has been
allocated.
|
Modifier and Type | Method and Description |
---|---|
SlotRequestId |
SingleLogicalSlot.getSlotRequestId() |
SlotRequestId |
SlotPoolImpl.PendingRequest.getSlotRequestId() |
SlotRequestId |
SlotSharingManager.TaskSlot.getSlotRequestId() |
Modifier and Type | Method and Description |
---|---|
Optional<PhysicalSlot> |
SlotPool.allocateAvailableSlot(SlotRequestId slotRequestId,
AllocationID allocationID)
Allocates the available slot with the given allocation id under the given request id.
|
Optional<PhysicalSlot> |
SlotPoolImpl.allocateAvailableSlot(SlotRequestId slotRequestId,
AllocationID allocationID) |
default CompletableFuture<LogicalSlot> |
SlotProvider.allocateBatchSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile)
Allocating batch slot with specific requirement.
|
CompletableFuture<LogicalSlot> |
SchedulerImpl.allocateBatchSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile) |
CompletableFuture<LogicalSlot> |
ThrowingSlotProvider.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile,
Time allocationTimeout) |
CompletableFuture<LogicalSlot> |
SlotProvider.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile,
Time allocationTimeout)
Allocating slot with specific requirement.
|
CompletableFuture<LogicalSlot> |
SchedulerImpl.allocateSlot(SlotRequestId slotRequestId,
ScheduledUnit scheduledUnit,
SlotProfile slotProfile,
Time allocationTimeout) |
void |
ThrowingSlotProvider.cancelSlotRequest(SlotRequestId slotRequestId,
SlotSharingGroupId slotSharingGroupId,
Throwable cause) |
void |
SlotProvider.cancelSlotRequest(SlotRequestId slotRequestId,
SlotSharingGroupId slotSharingGroupId,
Throwable cause)
Cancels the slot request with the given
SlotRequestId and SlotSharingGroupId . |
void |
SchedulerImpl.cancelSlotRequest(SlotRequestId slotRequestId,
SlotSharingGroupId slotSharingGroupId,
Throwable cause) |
boolean |
SlotSharingManager.contains(SlotRequestId slotRequestId) |
void |
AllocatedSlotActions.releaseSlot(SlotRequestId slotRequestId,
Throwable cause)
Releases the slot with the given
SlotRequestId . |
void |
SlotPoolImpl.releaseSlot(SlotRequestId slotRequestId,
Throwable cause) |
CompletableFuture<PhysicalSlot> |
SlotPool.requestNewAllocatedBatchSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile)
Requests the allocation of a new batch slot from the resource manager.
|
CompletableFuture<PhysicalSlot> |
SlotPoolImpl.requestNewAllocatedBatchSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile) |
CompletableFuture<PhysicalSlot> |
SlotPool.requestNewAllocatedSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile,
Time timeout)
Request the allocation of a new slot from the resource manager.
|
CompletableFuture<PhysicalSlot> |
SlotPoolImpl.requestNewAllocatedSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile,
Time timeout) |
protected void |
SlotPoolImpl.timeoutPendingSlotRequest(SlotRequestId slotRequestId) |
Constructor and Description |
---|
SingleLogicalSlot(SlotRequestId slotRequestId,
SlotContext slotContext,
SlotSharingGroupId slotSharingGroupId,
Locality locality,
SlotOwner slotOwner) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.