Package org.apache.flink.runtime.registration

Interface Summary

Interface	Description
RegistrationConnectionListener<T extends RegisteredRpcConnection<?,?,S,?>,S extends RegistrationResponse.Success,R extends RegistrationResponse.Rejection>	Classes which want to be notified about the registration result by the RegisteredRpcConnection have to implement this interface.

Class Summary

Class	Description
RegisteredRpcConnection<F extends Serializable,G extends RpcGateway,S extends RegistrationResponse.Success,R extends RegistrationResponse.Rejection>	This utility class implements the basis of RPC connecting from one component to another component, for example the RPC connection from TaskExecutor to ResourceManager.
RegistrationResponse	Base class for responses given to registration attempts from RetryingRegistration.
RegistrationResponse.Failure	A registration failure.
RegistrationResponse.Rejection	A rejected (declined) registration.
RegistrationResponse.Success	Base class for a successful registration.
RetryingRegistration<F extends Serializable,G extends RpcGateway,S extends RegistrationResponse.Success,R extends RegistrationResponse.Rejection>	This utility class implements the basis of registering one component at another component, for example registering the TaskExecutor at the ResourceManager.
RetryingRegistrationConfiguration	Configuration for the cluster components.