Modifier and Type | Method and Description |
---|---|
SlotID |
TaskManagerSlot.getSlotId() |
Constructor and Description |
---|
TaskManagerSlot(SlotID slotId,
ResourceProfile resourceProfile,
TaskExecutorConnection taskManagerConnection,
AllocationID allocationId) |
Modifier and Type | Method and Description |
---|---|
void |
ResourceManagerGateway.notifySlotAvailable(UUID resourceManagerLeaderId,
InstanceID instanceId,
SlotID slotID,
AllocationID oldAllocationId)
Sent by the TaskExecutor to notify the ResourceManager that a slot has become available.
|
void |
ResourceManager.notifySlotAvailable(UUID resourceManagerLeaderId,
InstanceID instanceID,
SlotID slotId,
AllocationID allocationId)
Notification from a TaskExecutor that a slot has become available
|
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 |
---|---|
Acknowledge |
TaskExecutor.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
String targetAddress,
UUID rmLeaderId)
Requests a slot from the TaskManager
|
Future<Acknowledge> |
TaskExecutorGateway.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
String targetAddress,
UUID resourceManagerLeaderId,
Time timeout)
Requests a slot from the TaskManager
|
Constructor and Description |
---|
SlotStatus(SlotID slotID,
ResourceProfile resourceProfile) |
SlotStatus(SlotID slotID,
ResourceProfile resourceProfile,
JobID jobID,
AllocationID allocationID) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.