org.apache.flink.runtime.taskexecutor

Class TaskExecutorToResourceManagerConnection

java.lang.Object

org.apache.flink.runtime.registration.RegisteredRpcConnection<ResourceManagerId,ResourceManagerGateway,TaskExecutorRegistrationSuccess>

org.apache.flink.runtime.taskexecutor.TaskExecutorToResourceManagerConnection

public class TaskExecutorToResourceManagerConnection
extends RegisteredRpcConnection<ResourceManagerId,ResourceManagerGateway,TaskExecutorRegistrationSuccess>

The connection between a TaskExecutor and the ResourceManager.

Field Summary

Fields inherited from class org.apache.flink.runtime.registration.RegisteredRpcConnection

log

Constructor Summary

Constructors

Constructor and Description

TaskExecutorToResourceManagerConnection(org.slf4j.Logger log, RpcService rpcService, String taskManagerAddress, ResourceID taskManagerResourceId, int dataPort, HardwareDescription hardwareDescription, String resourceManagerAddress, ResourceManagerId resourceManagerId, Executor executor, RegistrationConnectionListener<TaskExecutorToResourceManagerConnection,TaskExecutorRegistrationSuccess> registrationListener)

Method Summary

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.

Methods inherited from class org.apache.flink.runtime.registration.RegisteredRpcConnection

close, getTargetAddress, getTargetGateway, getTargetLeaderId, isClosed, isConnected, start, toString, tryReconnect

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

TaskExecutorToResourceManagerConnection

public TaskExecutorToResourceManagerConnection(org.slf4j.Logger log,
                                               RpcService rpcService,
                                               String taskManagerAddress,
                                               ResourceID taskManagerResourceId,
                                               int dataPort,
                                               HardwareDescription hardwareDescription,
                                               String resourceManagerAddress,
                                               ResourceManagerId resourceManagerId,
                                               Executor executor,
                                               RegistrationConnectionListener<TaskExecutorToResourceManagerConnection,TaskExecutorRegistrationSuccess> registrationListener)

Method Detail

generateRegistration

protected RetryingRegistration<ResourceManagerId,ResourceManagerGateway,TaskExecutorRegistrationSuccess> generateRegistration()

Description copied from class: RegisteredRpcConnection

This method generate a specific Registration, for example TaskExecutor Registration at the ResourceManager.

Specified by:

generateRegistration in class RegisteredRpcConnection<ResourceManagerId,ResourceManagerGateway,TaskExecutorRegistrationSuccess>

onRegistrationSuccess

protected void onRegistrationSuccess(TaskExecutorRegistrationSuccess success)

Description copied from class: RegisteredRpcConnection

This method handle the Registration Response.

Specified by:

onRegistrationSuccess in class RegisteredRpcConnection<ResourceManagerId,ResourceManagerGateway,TaskExecutorRegistrationSuccess>

onRegistrationFailure

protected void onRegistrationFailure(Throwable failure)

Description copied from class: RegisteredRpcConnection

This method handle the Registration failure.

Specified by:

onRegistrationFailure in class RegisteredRpcConnection<ResourceManagerId,ResourceManagerGateway,TaskExecutorRegistrationSuccess>