Package | Description |
---|---|
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.jobmaster.slotpool |
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 |
PhysicalSlotRequest.getSlotRequestId() |
SlotRequestId |
PhysicalSlotRequest.Result.getSlotRequestId() |
SlotRequestId |
SingleLogicalSlot.getSlotRequestId() |
SlotRequestId |
SlotPoolImpl.PendingRequest.getSlotRequestId() |
Modifier and Type | Method and Description |
---|---|
DualKeyLinkedMap<SlotRequestId,AllocationID,SlotPoolImpl.PendingRequest> |
SlotPoolImpl.getPendingRequests() |
Modifier and Type | Method and Description |
---|---|
Optional<PhysicalSlot> |
DeclarativeSlotPoolBridge.allocateAvailableSlot(SlotRequestId slotRequestId,
AllocationID allocationID,
ResourceProfile requirementProfile) |
Optional<PhysicalSlot> |
SlotPool.allocateAvailableSlot(SlotRequestId slotRequestId,
AllocationID allocationID,
ResourceProfile requirementProfile)
Allocates the available slot with the given allocation id under the given request id for the
given requirement profile.
|
Optional<PhysicalSlot> |
SlotPoolImpl.allocateAvailableSlot(SlotRequestId slotRequestId,
AllocationID allocationID,
ResourceProfile requirementProfile) |
static SingleLogicalSlot |
SingleLogicalSlot.allocateFromPhysicalSlot(SlotRequestId slotRequestId,
PhysicalSlot physicalSlot,
Locality locality,
SlotOwner slotOwner,
boolean slotWillBeOccupiedIndefinitely) |
void |
PhysicalSlotProvider.cancelSlotRequest(SlotRequestId slotRequestId,
Throwable cause)
Cancels the slot request with the given
SlotRequestId . |
void |
PhysicalSlotProviderImpl.cancelSlotRequest(SlotRequestId slotRequestId,
Throwable cause) |
void |
DeclarativeSlotPoolBridge.releaseSlot(SlotRequestId slotRequestId,
Throwable cause) |
void |
AllocatedSlotActions.releaseSlot(SlotRequestId slotRequestId,
Throwable cause)
Releases the slot with the given
SlotRequestId . |
void |
SlotPoolImpl.releaseSlot(SlotRequestId slotRequestId,
Throwable cause) |
CompletableFuture<PhysicalSlot> |
DeclarativeSlotPoolBridge.requestNewAllocatedBatchSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile) |
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> |
DeclarativeSlotPoolBridge.requestNewAllocatedSlot(SlotRequestId slotRequestId,
ResourceProfile resourceProfile,
Time timeout) |
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 |
---|
PhysicalSlotRequest(SlotRequestId slotRequestId,
SlotProfile slotProfile,
boolean slotWillBeOccupiedIndefinitely) |
Result(SlotRequestId slotRequestId,
PhysicalSlot physicalSlot) |
SingleLogicalSlot(SlotRequestId slotRequestId,
SlotContext slotContext,
Locality locality,
SlotOwner slotOwner) |
SingleLogicalSlot(SlotRequestId slotRequestId,
SlotContext slotContext,
Locality locality,
SlotOwner slotOwner,
boolean willBeOccupiedIndefinitely) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.