Package | Description |
---|---|
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.runtime.resourcemanager.slotmanager | |
org.apache.flink.runtime.taskexecutor.slot |
Modifier and Type | Method and Description |
---|---|
void |
ResourceManagerGateway.heartbeatFromTaskManager(ResourceID heartbeatOrigin,
SlotReport slotReport)
Sends the heartbeat to resource manager from task manager
|
void |
ResourceManager.heartbeatFromTaskManager(ResourceID resourceID,
SlotReport slotReport) |
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 |
---|---|
void |
SlotManager.registerTaskManager(TaskExecutorConnection taskExecutorConnection,
SlotReport initialSlotReport)
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.
|
Modifier and Type | Method and Description |
---|---|
SlotReport |
TaskSlotTable.createSlotReport(ResourceID resourceId) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.