public class TaskExecutorToResourceManagerConnection extends RegisteredRpcConnection<ResourceManagerId,ResourceManagerGateway,TaskExecutorRegistrationSuccess>
log
Constructor and Description |
---|
TaskExecutorToResourceManagerConnection(org.slf4j.Logger log,
RpcService rpcService,
String taskManagerAddress,
ResourceID taskManagerResourceId,
SlotReport slotReport,
String resourceManagerAddress,
ResourceManagerId resourceManagerId,
Executor executor,
RegistrationConnectionListener<TaskExecutorRegistrationSuccess> registrationListener) |
Modifier and Type | Method and Description |
---|---|
protected RetryingRegistration<ResourceManagerId,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, ResourceManagerId resourceManagerId, Executor executor, RegistrationConnectionListener<TaskExecutorRegistrationSuccess> registrationListener)
protected RetryingRegistration<ResourceManagerId,ResourceManagerGateway,TaskExecutorRegistrationSuccess> generateRegistration()
RegisteredRpcConnection
protected void onRegistrationSuccess(TaskExecutorRegistrationSuccess success)
RegisteredRpcConnection
protected void onRegistrationFailure(Throwable failure)
RegisteredRpcConnection
public InstanceID getRegistrationId()
public ResourceID getResourceManagerId()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.