Package | Description |
---|---|
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.registration | |
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.runtime.taskexecutor |
Modifier and Type | Class and Description |
---|---|
class |
JMTMRegistrationSuccess |
class |
JobMasterRegistrationSuccess
Base class for responses from the ResourceManager to a registration attempt by a JobMaster.
|
Modifier and Type | Method and Description |
---|---|
Future<RegistrationResponse> |
JobMaster.registerTaskManager(String taskManagerRpcAddress,
TaskManagerLocation taskManagerLocation,
UUID leaderId) |
Future<RegistrationResponse> |
JobMasterGateway.registerTaskManager(String taskManagerRpcAddress,
TaskManagerLocation taskManagerLocation,
UUID leaderId,
Time timeout)
Register the task manager at the job manager.
|
Modifier and Type | Class and Description |
---|---|
static class |
RegistrationResponse.Decline
A rejected (declined) registration.
|
static class |
RegistrationResponse.Success
Base class for a successful registration.
|
Modifier and Type | Method and Description |
---|---|
protected abstract Future<RegistrationResponse> |
RetryingRegistration.invokeRegistration(Gateway gateway,
UUID leaderId,
long timeoutMillis) |
Modifier and Type | Method and Description |
---|---|
Future<RegistrationResponse> |
ResourceManager.registerJobManager(UUID resourceManagerLeaderId,
UUID jobManagerLeaderId,
ResourceID jobManagerResourceId,
String jobManagerAddress,
JobID jobId) |
Future<RegistrationResponse> |
ResourceManagerGateway.registerJobManager(UUID resourceManagerLeaderId,
UUID jobMasterLeaderId,
ResourceID jobMasterResourceId,
String jobMasterAddress,
JobID jobID,
Time timeout)
Register a
JobMaster at the resource manager. |
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 | Class and Description |
---|---|
class |
TaskExecutorRegistrationSuccess
Base class for responses from the ResourceManager to a registration attempt by a
TaskExecutor.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.