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) |
protected void |
ResourceManager.releaseResource(InstanceID instanceId,
Exception cause) |
CompletableFuture<Acknowledge> |
ResourceManagerGateway.sendSlotReport(ResourceID taskManagerResourceId,
InstanceID taskManagerRegistrationId,
SlotReport slotReport,
Time timeout)
Sends the given
SlotReport to the ResourceManager. |
CompletableFuture<Acknowledge> |
ResourceManager.sendSlotReport(ResourceID taskManagerResourceId,
InstanceID taskManagerRegistrationId,
SlotReport slotReport,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
InstanceID |
TaskExecutorConnection.getInstanceID() |
Modifier and Type | Method and Description |
---|---|
InstanceID |
TaskManagerSlot.getInstanceId() |
InstanceID |
TaskManagerRegistration.getInstanceId() |
InstanceID |
TaskManagerSlotInformation.getInstanceId() |
Modifier and Type | Method and Description |
---|---|
ResourceProfile |
DeclarativeSlotManager.getFreeResourceOf(InstanceID instanceID) |
ResourceProfile |
SlotManager.getFreeResourceOf(InstanceID instanceID) |
ResourceProfile |
SlotManagerImpl.getFreeResourceOf(InstanceID instanceID) |
int |
DeclarativeSlotManager.getNumberFreeSlotsOf(InstanceID instanceId) |
int |
SlotManager.getNumberFreeSlotsOf(InstanceID instanceId) |
int |
SlotManagerImpl.getNumberFreeSlotsOf(InstanceID instanceId) |
int |
DeclarativeSlotManager.getNumberRegisteredSlotsOf(InstanceID instanceId) |
int |
SlotManager.getNumberRegisteredSlotsOf(InstanceID instanceId) |
int |
SlotManagerImpl.getNumberRegisteredSlotsOf(InstanceID instanceId) |
ResourceProfile |
DeclarativeSlotManager.getRegisteredResourceOf(InstanceID instanceID) |
ResourceProfile |
SlotManager.getRegisteredResourceOf(InstanceID instanceID) |
ResourceProfile |
SlotManagerImpl.getRegisteredResourceOf(InstanceID instanceID) |
void |
ResourceActions.releaseResource(InstanceID instanceId,
Exception cause)
Releases the resource with the given instance id.
|
boolean |
DeclarativeSlotManager.reportSlotStatus(InstanceID instanceId,
SlotReport slotReport)
Reports the current slot allocations for a task manager identified by the given instance id.
|
boolean |
SlotManager.reportSlotStatus(InstanceID instanceId,
SlotReport slotReport)
Reports the current slot allocations for a task manager identified by the given instance id.
|
boolean |
SlotManagerImpl.reportSlotStatus(InstanceID instanceId,
SlotReport slotReport)
Reports the current slot allocations for a task manager identified by the given instance id.
|
boolean |
DeclarativeSlotManager.unregisterTaskManager(InstanceID instanceId,
Exception cause) |
boolean |
SlotManager.unregisterTaskManager(InstanceID instanceId,
Exception cause)
Unregisters the task manager identified by the given instance id and its associated slots
from the slot manager.
|
boolean |
SlotManagerImpl.unregisterTaskManager(InstanceID instanceId,
Exception cause) |
Modifier and Type | Method and Description |
---|---|
<T extends TaskManagerSlotInformation> |
LeastUtilizationSlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup) |
<T extends TaskManagerSlotInformation> |
AnyMatchingSlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup) |
<T extends TaskManagerSlotInformation> |
SlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup)
Finds a matching slot for the requested
ResourceProfile given the collection of free
slots and the total number of slots per TaskExecutor. |
Modifier and Type | Method and Description |
---|---|
InstanceID |
TaskExecutorRegistrationSuccess.getRegistrationId()
Gets the ID that the ResourceManager assigned the registration.
|
Constructor and Description |
---|
TaskExecutorRegistrationSuccess(InstanceID registrationId,
ResourceID resourceManagerResourceId,
ClusterInformation clusterInformation)
Create a new
TaskExecutorRegistrationSuccess message. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.