org.apache.drill.exec.rpc.data

Class DataConnectionManager

java.lang.Object

org.apache.drill.exec.rpc.ReconnectingConnection<DataClientConnection,BitData.BitClientHandshake>

org.apache.drill.exec.rpc.data.DataConnectionManager

All Implemented Interfaces:

Closeable, AutoCloseable

public class DataConnectionManager
extends ReconnectingConnection<DataClientConnection,BitData.BitClientHandshake>

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
DataConnectionManager(CoordinationProtos.DrillbitEndpoint remoteEndpoint, org.apache.drill.exec.rpc.data.DataConnectionConfig config)

Method Summary

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

DataConnectionManager

public DataConnectionManager(CoordinationProtos.DrillbitEndpoint remoteEndpoint,
                             org.apache.drill.exec.rpc.data.DataConnectionConfig config)

Method Detail

getNewClient

protected DataClient getNewClient()

Specified by:

getNewClient in class ReconnectingConnection<DataClientConnection,BitData.BitClientHandshake>