Package org.apache.drill.exec.rpc

Interface Summary

Interface	Description
ChannelListenerWithCoordinationId
ClientConnection
ConnectionConfig
ConnectionThrottle
DrillRpcFuture<T>
EncryptionContext
OutOfMemoryHandler
RemoteConnection
RequestHandler<S extends ServerConnection<S>>	Note that if a handler maintains any internal state, the state will be disposed if the handler on the connection changes.
ResponseSender
RpcCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>
RpcConnectionHandler<T extends RemoteConnection>
RpcMetrics	Holder interface for all the metrics used in RPC layer
RpcOutcome<T>
RpcOutcomeListener<V>
SaslCodec
ServerConnection<S extends ServerConnection<S>>
UserClientConnection	Interface for getting user session properties and interacting with user connection.

Class Summary

Class	Description
AbstractClientConnection
AbstractConnectionConfig
AbstractDisposableUserClientConnection	Helps to run a query and await on the results.
AbstractHandshakeHandler<T extends com.google.protobuf.MessageLite>
AbstractRemoteConnection
AbstractRpcMetrics
AbstractServerConnection<S extends ServerConnection<S>>
Acks
BaseRpcOutcomeListener<T>
BasicClient<T extends com.google.protobuf.Internal.EnumLite,CC extends ClientConnection,HS extends com.google.protobuf.MessageLite,HR extends com.google.protobuf.MessageLite>
BasicServer<T extends com.google.protobuf.Internal.EnumLite,SC extends ServerConnection<SC>>	A server is bound to a port and is responsible for responding to various type of requests.
BasicServer.ServerHandshakeHandler<T extends com.google.protobuf.MessageLite>
BitConnectionConfig
BitRpcUtility	Utility class providing common methods shared between DataClient and ControlClient
ConnectionMultiListener<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 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.SSLHandshakeListener
DynamicSemaphore	Dynamic credit based flow control: The sender initially sends batch to the sender by the initial static credit (3).
EncryptionContextImpl	Context to help initializing encryption related configurations for a connection.
FailingRequestHandler<S extends ServerConnection<S>>	This handler fails any request on the connection.
FutureBitCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>
InboundRpcMessage
ListeningCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>
NamedThreadFactory	ThreadFactory for ExecutorServices that names threads sequentially.
OutboundRpcMessage
ProtobufLengthDecoder	Modified version of io.netty.handler.codec.protobuf.ProtobufVarint32FrameDecoder that avoids bytebuf copy.
ReconnectingConnection<C extends ClientConnection,HS extends com.google.protobuf.MessageLite>	Manager all connections between two particular bits.
ResettableBarrier	Modified implementation of countdown latch that allows a barrier to be unilaterally opened and closed.
Response
RpcBus<T extends com.google.protobuf.Internal.EnumLite,C extends RemoteConnection>	The Rpc Bus deals with incoming and outgoing communication and is used on both the server and the client side of a system.
RpcCheckedFuture<T>
RpcConfig
RpcConfig.RpcConfigBuilder
RpcConfig.RpcMessageType<SEND extends com.google.protobuf.MessageLite,RECEIVE extends com.google.protobuf.MessageLite,T extends com.google.protobuf.Internal.EnumLite>
RpcConstants
RpcExceptionHandler<C extends RemoteConnection>
RpcMessage
TransportCheck	TransportCheck decides whether or not to use the native EPOLL mechanism for communication.

Enum Summary

Enum	Description
RpcConnectionHandler.FailureType

Exception Summary

Exception	Description
ChannelClosedException
NonTransientRpcException
RpcException	Parent class for all rpc exceptions.
UserRpcException