Package org.apache.drill.exec.rpc

Class ReconnectingConnection<C extends ClientConnection,HS extends com.google.protobuf.MessageLite>

java.lang.Object

org.apache.drill.exec.rpc.ReconnectingConnection<C,HS>

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

ControlConnectionManager, DataConnectionManager

public abstract class ReconnectingConnection<C extends ClientConnection,HS extends com.google.protobuf.MessageLite>
extends Object
implements Closeable

Manager all connections between two particular bits.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	ReconnectingConnection.CloseHandler	Listens for connection closes and clears connection holder.
class	ReconnectingConnection.CloseHandlerCreator	Factory for close handlers
class	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
ReconnectingConnection(HS handshake, String host, int port)

Method Summary

Modifier and Type	Method	Description
void	addExternalConnection(C connection)
void	close()
ReconnectingConnection<C,HS>.CloseHandlerCreator	getCloseHandlerCreator()
protected abstract BasicClient<?,C,HS,?>	getNewClient()
<T extends com.google.protobuf.MessageLite, E extends com.google.protobuf.Internal.EnumLite, M extends com.google.protobuf.MessageLite, R extends RpcCommand<T, C, E, M>> void	runCommand(R cmd)

Methods inherited from class java.lang.Object

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

Constructor Details

ReconnectingConnection

public ReconnectingConnection(HS handshake,
 String host,
 int port)

Method Details

getNewClient

protected abstract BasicClient<?,C,HS,?> getNewClient()

runCommand

public <T extends com.google.protobuf.MessageLite,
E extends com.google.protobuf.Internal.EnumLite,
M extends com.google.protobuf.MessageLite,
R extends RpcCommand<T,
C,
E,
M>>
void runCommand(R cmd)

getCloseHandlerCreator

public ReconnectingConnection<C,HS>.CloseHandlerCreator getCloseHandlerCreator()

addExternalConnection

public void addExternalConnection(C connection)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable