Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
ResourceManager.sendSlotReport(ResourceID taskManagerResourceId,
InstanceID taskManagerRegistrationId,
SlotReport slotReport,
Time timeout) |
CompletableFuture<Acknowledge> |
ResourceManagerGateway.sendSlotReport(ResourceID taskManagerResourceId,
InstanceID taskManagerRegistrationId,
SlotReport slotReport,
Time timeout)
Sends the given
SlotReport to the ResourceManager. |
Modifier and Type | Method and Description |
---|---|
boolean |
SlotManager.registerTaskManager(TaskExecutorConnection taskExecutorConnection,
SlotReport initialSlotReport,
ResourceProfile totalResourceProfile,
ResourceProfile defaultSlotResourceProfile)
Registers a new task manager at the slot manager.
|
boolean |
DeclarativeSlotManager.registerTaskManager(TaskExecutorConnection taskExecutorConnection,
SlotReport initialSlotReport,
ResourceProfile totalResourceProfile,
ResourceProfile defaultSlotResourceProfile)
Registers a new task manager at the slot manager.
|
boolean |
FineGrainedSlotManager.registerTaskManager(TaskExecutorConnection taskExecutorConnection,
SlotReport initialSlotReport,
ResourceProfile totalResourceProfile,
ResourceProfile defaultSlotResourceProfile)
Registers a new task manager at the slot manager.
|
boolean |
SlotManager.reportSlotStatus(InstanceID instanceId,
SlotReport slotReport)
Reports the current slot allocations for a task manager identified by the given instance id.
|
boolean |
DefaultSlotStatusSyncer.reportSlotStatus(InstanceID instanceId,
SlotReport slotReport) |
boolean |
SlotStatusSyncer.reportSlotStatus(InstanceID instanceId,
SlotReport slotReport)
Reconcile the slot status with the slot report.
|
boolean |
DeclarativeSlotManager.reportSlotStatus(InstanceID instanceId,
SlotReport slotReport)
Reports the current slot allocations for a task manager identified by the given instance id.
|
boolean |
FineGrainedSlotManager.reportSlotStatus(InstanceID instanceId,
SlotReport slotReport)
Reports the current slot allocations for a task manager identified by the given instance id.
|
Modifier and Type | Method and Description |
---|---|
SlotReport |
TaskExecutorHeartbeatPayload.getSlotReport() |
Constructor and Description |
---|
TaskExecutorHeartbeatPayload(SlotReport slotReport,
ClusterPartitionReport clusterPartitionReport) |
Modifier and Type | Method and Description |
---|---|
SlotReport |
TaskSlotTable.createSlotReport(ResourceID resourceId) |
SlotReport |
TaskSlotTableImpl.createSlotReport(ResourceID resourceId) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.