Modifier and Type | Method and Description |
---|---|
InstanceID |
Instance.getId() |
Constructor and Description |
---|
Instance(TaskManagerGateway taskManagerGateway,
TaskManagerLocation location,
InstanceID id,
HardwareDescription resources,
int numberOfSlots)
Constructs an instance reflecting a registered TaskManager.
|
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 |
TaskManagerSlotInformation.getInstanceId() |
InstanceID |
TaskManagerRegistration.getInstanceId() |
InstanceID |
TaskManagerSlot.getInstanceId() |
Modifier and Type | Method and Description |
---|---|
int |
SlotManagerImpl.getNumberFreeSlotsOf(InstanceID instanceId) |
int |
SlotManager.getNumberFreeSlotsOf(InstanceID instanceId) |
int |
SlotManagerImpl.getNumberRegisteredSlotsOf(InstanceID instanceId) |
int |
SlotManager.getNumberRegisteredSlotsOf(InstanceID instanceId) |
void |
ResourceActions.releaseResource(InstanceID instanceId,
Exception cause)
Releases the resource with 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 |
SlotManager.reportSlotStatus(InstanceID instanceId,
SlotReport slotReport)
Reports the current slot allocations for a task manager identified by the given instance id.
|
boolean |
SlotManagerImpl.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.
|
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> |
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. |
<T extends TaskManagerSlotInformation> |
AnyMatchingSlotMatchingStrategy.findMatchingSlot(ResourceProfile requestedProfile,
Collection<T> freeSlots,
java.util.function.Function<InstanceID,Integer> numberRegisteredSlotsLookup) |
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–2020 The Apache Software Foundation. All rights reserved.