public class TaskExecutorToResourceManagerConnection extends RegisteredRpcConnection<ResourceManagerGateway,TaskExecutorRegistrationSuccess>
log
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 |
---|---|
protected RetryingRegistration<ResourceManagerGateway,TaskExecutorRegistrationSuccess> |
generateRegistration()
This method generate a specific Registration, for example TaskExecutor Registration at the ResourceManager
|
InstanceID |
getRegistrationId()
Gets the ID under which the TaskExecutor is registered at the ResourceManager.
|
ResourceID |
getResourceManagerId()
Gets the unique id of ResourceManager, that is returned when registration success.
|
protected void |
onRegistrationFailure(Throwable failure)
This method handle the Registration failure
|
protected void |
onRegistrationSuccess(TaskExecutorRegistrationSuccess success)
This method handle the Registration Response
|
close, getTargetAddress, getTargetGateway, getTargetLeaderId, isClosed, isConnected, start, toString
public TaskExecutorToResourceManagerConnection(org.slf4j.Logger log, RpcService rpcService, String taskManagerAddress, ResourceID taskManagerResourceId, SlotReport slotReport, String resourceManagerAddress, UUID resourceManagerLeaderId, Executor executor, RegistrationConnectionListener<TaskExecutorRegistrationSuccess> registrationListener)
protected RetryingRegistration<ResourceManagerGateway,TaskExecutorRegistrationSuccess> generateRegistration()
RegisteredRpcConnection
generateRegistration
in class RegisteredRpcConnection<ResourceManagerGateway,TaskExecutorRegistrationSuccess>
protected void onRegistrationSuccess(TaskExecutorRegistrationSuccess success)
RegisteredRpcConnection
onRegistrationSuccess
in class RegisteredRpcConnection<ResourceManagerGateway,TaskExecutorRegistrationSuccess>
protected void onRegistrationFailure(Throwable failure)
RegisteredRpcConnection
onRegistrationFailure
in class RegisteredRpcConnection<ResourceManagerGateway,TaskExecutorRegistrationSuccess>
public InstanceID getRegistrationId()
public ResourceID getResourceManagerId()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.