org.apache.drill.exec.rpc.control

Class RemoteControlConnectionManager

java.lang.Object

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

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

org.apache.drill.exec.rpc.control.RemoteControlConnectionManager

All Implemented Interfaces:

Closeable, AutoCloseable

public class RemoteControlConnectionManager
extends ControlConnectionManager

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 and Description
RemoteControlConnectionManager(ControlConnectionConfig config, CoordinationProtos.DrillbitEndpoint localEndpoint, CoordinationProtos.DrillbitEndpoint remoteEndpoint)

Method Summary

Modifier and Type	Method and Description
protected 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 Detail

RemoteControlConnectionManager

public RemoteControlConnectionManager(ControlConnectionConfig config,
                                      CoordinationProtos.DrillbitEndpoint localEndpoint,
                                      CoordinationProtos.DrillbitEndpoint remoteEndpoint)

Method Detail

getNewClient

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

Specified by:

getNewClient in class ControlConnectionManager