Modifier and Type | Method and Description |
---|---|
Future<RegistrationResponse> |
ResourceManager.registerTaskExecutor(UUID resourceManagerLeaderId,
String taskExecutorAddress,
ResourceID taskExecutorResourceId,
SlotReport slotReport)
Register a
TaskExecutor at the resource manager |
Future<RegistrationResponse> |
ResourceManagerGateway.registerTaskExecutor(UUID resourceManagerLeaderId,
String taskExecutorAddress,
ResourceID resourceID,
SlotReport slotReport,
Time timeout)
Register a
TaskExecutor at the resource manager. |
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.
|
Constructor and Description |
---|
TaskExecutorToResourceManagerConnection(org.slf4j.Logger log,
RpcService rpcService,
String taskManagerAddress,
ResourceID taskManagerResourceId,
SlotReport slotReport,
String resourceManagerAddress,
UUID resourceManagerLeaderId,
Executor executor,
RegistrationConnectionListener<TaskExecutorRegistrationSuccess> registrationListener) |
Modifier and Type | Method and Description |
---|---|
SlotReport |
TaskSlotTable.createSlotReport(ResourceID resourceId) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.