public class TaskExecutorToResourceManagerConnection extends RegisteredRpcConnection<ResourceManagerId,ResourceManagerGateway,TaskExecutorRegistrationSuccess>
log
Constructor and Description |
---|
TaskExecutorToResourceManagerConnection(org.slf4j.Logger log,
RpcService rpcService,
RetryingRegistrationConfiguration retryingRegistrationConfiguration,
String resourceManagerAddress,
ResourceManagerId resourceManagerId,
Executor executor,
RegistrationConnectionListener<TaskExecutorToResourceManagerConnection,TaskExecutorRegistrationSuccess> registrationListener,
TaskExecutorRegistration taskExecutorRegistration) |
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.
|
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, tryReconnect
public TaskExecutorToResourceManagerConnection(org.slf4j.Logger log, RpcService rpcService, RetryingRegistrationConfiguration retryingRegistrationConfiguration, String resourceManagerAddress, ResourceManagerId resourceManagerId, Executor executor, RegistrationConnectionListener<TaskExecutorToResourceManagerConnection,TaskExecutorRegistrationSuccess> registrationListener, TaskExecutorRegistration taskExecutorRegistration)
protected RetryingRegistration<ResourceManagerId,ResourceManagerGateway,TaskExecutorRegistrationSuccess> generateRegistration()
RegisteredRpcConnection
protected void onRegistrationSuccess(TaskExecutorRegistrationSuccess success)
RegisteredRpcConnection
protected void onRegistrationFailure(Throwable failure)
RegisteredRpcConnection
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.