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

Method Summary

Modifier and Type	Method	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 Details

DataConnectionManager

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

Method Details

getNewClient

protected DataClient getNewClient()

Specified by:

getNewClient in class ReconnectingConnection<DataClientConnection,BitData.BitClientHandshake>