Modifier and Type | Method and Description |
---|---|
static SlotID |
SlotID.getDynamicSlotID(ResourceID resourceID)
Get a SlotID without actual slot index for dynamic slot allocation.
|
Modifier and Type | Method and Description |
---|---|
void |
ResourceManagerGateway.notifySlotAvailable(InstanceID instanceId,
SlotID slotID,
AllocationID oldAllocationId)
Sent by the TaskExecutor to notify the ResourceManager that a slot has become available.
|
void |
ResourceManager.notifySlotAvailable(InstanceID instanceID,
SlotID slotId,
AllocationID allocationId) |
Modifier and Type | Method and Description |
---|---|
SlotID |
FineGrainedTaskManagerSlot.getSlotId() |
SlotID |
TaskManagerSlotInformation.getSlotId() |
Modifier and Type | Method and Description |
---|---|
Iterable<SlotID> |
TaskManagerRegistration.getSlots() |
Modifier and Type | Method and Description |
---|---|
void |
DefaultSlotTracker.addSlot(SlotID slotId,
ResourceProfile resourceProfile,
TaskExecutorConnection taskManagerConnection,
JobID assignedJob) |
boolean |
TaskManagerRegistration.containsSlot(SlotID slotId) |
void |
FineGrainedSlotManager.freeSlot(SlotID slotId,
AllocationID allocationId)
Free the given slot from the given allocation.
|
void |
DeclarativeSlotManager.freeSlot(SlotID slotId,
AllocationID allocationId)
Free the given slot from the given allocation.
|
void |
SlotManager.freeSlot(SlotID slotId,
AllocationID allocationId)
Free the given slot from the given allocation.
|
void |
DefaultSlotTracker.notifyAllocationComplete(SlotID slotId,
JobID jobId) |
void |
DefaultSlotTracker.notifyAllocationStart(SlotID slotId,
JobID jobId) |
void |
DefaultSlotTracker.notifyFree(SlotID slotId) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultSlotTracker.removeSlots(Iterable<SlotID> slotsToRemove) |
Constructor and Description |
---|
TaskManagerRegistration(TaskExecutorConnection taskManagerConnection,
Collection<SlotID> slots,
ResourceProfile totalResourceProfile,
ResourceProfile defaultSlotResourceProfile) |
Modifier and Type | Method and Description |
---|---|
SlotID |
SlotStatus.getSlotID()
Get the unique identification of this slot.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
TaskExecutorGatewayDecoratorBase.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
String targetAddress,
ResourceManagerId resourceManagerId,
Time timeout) |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
String targetAddress,
ResourceManagerId resourceManagerId,
Time timeout)
Requests a slot from the TaskManager.
|
CompletableFuture<Acknowledge> |
TaskExecutor.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
ResourceProfile resourceProfile,
String targetAddress,
ResourceManagerId resourceManagerId,
Time timeout) |
Constructor and Description |
---|
SlotStatus(SlotID slotID,
ResourceProfile resourceProfile) |
SlotStatus(SlotID slotID,
ResourceProfile resourceProfile,
JobID jobID,
AllocationID allocationID) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.