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

Class LocalControlConnectionManager

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.LocalControlConnectionManager

All Implemented Interfaces:

Closeable, AutoCloseable

public class LocalControlConnectionManager
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	Description
LocalControlConnectionManager(ControlConnectionConfig config, CoordinationProtos.DrillbitEndpoint localEndpoint)

Method Summary

Modifier and Type	Method	Description
protected BasicClient<?,ControlConnection,BitControl.BitControlHandshake,?>	getNewClient()
void	runCommand(RpcCommand cmd)

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

addExternalConnection, close, getCloseHandlerCreator

Methods inherited from class java.lang.Object

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

Constructor Details

LocalControlConnectionManager

public LocalControlConnectionManager(ControlConnectionConfig config,
 CoordinationProtos.DrillbitEndpoint localEndpoint)

Method Details

getNewClient

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

Specified by:

getNewClient in class ControlConnectionManager

runCommand

public void runCommand(RpcCommand cmd)

Overrides:

runCommand in class ReconnectingConnection<ControlConnection,BitControl.BitControlHandshake>