Package org.apache.drill.exec.rpc.control

Class ControlConnectionManager

java.lang.Object

org.apache.drill.exec.rpc.ReconnectingConnection<ControlConnection,BitControl.BitControlHandshake>

org.apache.drill.exec.rpc.control.ControlConnectionManager

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

LocalControlConnectionManager, RemoteControlConnectionManager

public abstract class ControlConnectionManager
extends ReconnectingConnection<ControlConnection,BitControl.BitControlHandshake>

Maintains connection between two particular bits.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.rpc.ReconnectingConnection

ReconnectingConnection.CloseHandler, ReconnectingConnection.CloseHandlerCreator, ReconnectingConnection.ConnectionListeningFuture<R extends com.google.protobuf.MessageLite,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>

Constructor Summary

Constructors

Constructor	Description
ControlConnectionManager(CoordinationProtos.DrillbitEndpoint localEndpoint, CoordinationProtos.DrillbitEndpoint remoteEndpoint)

Method Summary

Modifier and Type	Method	Description
protected abstract BasicClient<?,ControlConnection,BitControl.BitControlHandshake,?>	getNewClient()

Methods inherited from class org.apache.drill.exec.rpc.ReconnectingConnection

addExternalConnection, close, getCloseHandlerCreator, runCommand

Methods inherited from class java.lang.Object

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

Constructor Details

ControlConnectionManager

public ControlConnectionManager(CoordinationProtos.DrillbitEndpoint localEndpoint,
 CoordinationProtos.DrillbitEndpoint remoteEndpoint)

Method Details

getNewClient

protected abstract BasicClient<?,ControlConnection,BitControl.BitControlHandshake,?> getNewClient()

Specified by:

getNewClient in class ReconnectingConnection<ControlConnection,BitControl.BitControlHandshake>