Uses of Interface
org.apache.drill.exec.rpc.RpcConnectionHandler

Packages that use RpcConnectionHandler

Package	Description
org.apache.drill.exec.rpc
org.apache.drill.exec.rpc.control
org.apache.drill.exec.rpc.data
org.apache.drill.exec.rpc.user

Uses of RpcConnectionHandler in org.apache.drill.exec.rpc

Subinterfaces of RpcConnectionHandler in org.apache.drill.exec.rpc

Modifier and Type	Interface	Description
interface	RpcCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>

Classes in org.apache.drill.exec.rpc that implement RpcConnectionHandler

Modifier and Type	Class	Description
class	FutureBitCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>
class	ListeningCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>
class	ReconnectingConnection.ConnectionListeningFuture<R extends com.google.protobuf.MessageLite,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>

Methods in org.apache.drill.exec.rpc with parameters of type RpcConnectionHandler

Modifier and Type	Method	Description
protected void	BasicClient.connectAsClient(RpcConnectionHandler<CC> connectionListener, HS handshakeValue, String host, int port)
static <T extends com.google.protobuf.Internal.EnumLite, CC extends ClientConnection, HS extends com.google.protobuf.MessageLite, HR extends com.google.protobuf.MessageLite, BC extends BasicClient<T, CC, HS, HR>> ConnectionMultiListener.Builder<T,CC,HS,HR,BC>	ConnectionMultiListener.newBuilder(RpcConnectionHandler<CC> connectionListener, HS handshakeValue, BC basicClient)
protected abstract void	BasicClient.prepareSaslHandshake(RpcConnectionHandler<CC> connectionHandler, List<String> serverAuthMechanisms)	Creates various instances needed to start the SASL handshake.
static <T extends com.google.protobuf.Internal.EnumLite, CC extends ClientConnection, HS extends com.google.protobuf.MessageLite, HR extends com.google.protobuf.MessageLite> void	BitRpcUtility.prepareSaslHandshake(RpcConnectionHandler<CC> connectionHandler, List<String> serverAuthMechanisms, CC connection, BitConnectionConfig config, CoordinationProtos.DrillbitEndpoint endpoint, BasicClient<T,CC,HS,HR> client, T saslRpcType)	Creates various instances needed to start the SASL handshake.
protected void	BasicClient.startSaslHandshake(RpcConnectionHandler<CC> connectionHandler, Map<String,?> saslProperties, org.apache.hadoop.security.UserGroupInformation ugi, AuthenticatorFactory authFactory, T rpcType)	Main method which starts the SASL handshake for all client channels (user/data/control) once it's determined after regular RPC handshake that authentication is required by server side.

Uses of RpcConnectionHandler in org.apache.drill.exec.rpc.control

Classes in org.apache.drill.exec.rpc.control that implement RpcConnectionHandler

Modifier and Type	Class	Description
static class	ControlTunnel.CancelQuery
static class	ControlTunnel.CustomMessageSender
static class	ControlTunnel.ReceiverFinished
static class	ControlTunnel.RequestProfile
static class	ControlTunnel.SendFragment
static class	ControlTunnel.SendFragmentStatus
static class	ControlTunnel.SignalFragment
static class	ControlTunnel.SyncCustomMessageSender

Methods in org.apache.drill.exec.rpc.control with parameters of type RpcConnectionHandler

Modifier and Type	Method	Description
protected void	ControlClient.prepareSaslHandshake(RpcConnectionHandler<ControlConnection> connectionHandler, List<String> serverAuthMechanisms)

Uses of RpcConnectionHandler in org.apache.drill.exec.rpc.data

Methods in org.apache.drill.exec.rpc.data with parameters of type RpcConnectionHandler

Modifier and Type	Method	Description
protected void	DataClient.prepareSaslHandshake(RpcConnectionHandler<DataClientConnection> connectionHandler, List<String> serverAuthMechanisms)

Uses of RpcConnectionHandler in org.apache.drill.exec.rpc.user

Methods in org.apache.drill.exec.rpc.user that return RpcConnectionHandler

Modifier and Type	Method	Description
RpcConnectionHandler<UserClient.UserToBitConnection>	QueryResultHandler.getWrappedConnectionHandler(RpcConnectionHandler<UserClient.UserToBitConnection> handler)

Methods in org.apache.drill.exec.rpc.user with parameters of type RpcConnectionHandler

Modifier and Type	Method	Description
RpcConnectionHandler<UserClient.UserToBitConnection>	QueryResultHandler.getWrappedConnectionHandler(RpcConnectionHandler<UserClient.UserToBitConnection> handler)
protected void	UserClient.prepareSaslHandshake(RpcConnectionHandler<UserClient.UserToBitConnection> connectionHandler, List<String> serverAuthMechanisms)