Modifier and Type | Method and Description |
---|---|
SlotID |
TaskManagerSlot.getSlotId() |
Constructor and Description |
---|
TaskManagerSlot(SlotID slotId,
ResourceProfile resourceProfile,
TaskExecutorConnection taskManagerConnection) |
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 |
---|---|
Iterable<SlotID> |
TaskManagerRegistration.getSlots() |
Modifier and Type | Method and Description |
---|---|
boolean |
TaskManagerRegistration.containsSlot(SlotID slotId) |
void |
SlotManager.freeSlot(SlotID slotId,
AllocationID allocationId)
Free the given slot from the given allocation.
|
Constructor and Description |
---|
TaskManagerRegistration(TaskExecutorConnection taskManagerConnection,
Collection<SlotID> slots) |
Modifier and Type | Method and Description |
---|---|
SlotID |
SlotStatus.getSlotID()
Get the unique identification of this slot.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
TaskExecutorGateway.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
String targetAddress,
ResourceManagerId resourceManagerId,
Time timeout)
Requests a slot from the TaskManager.
|
CompletableFuture<Acknowledge> |
TaskExecutor.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
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–2020 The Apache Software Foundation. All rights reserved.