Package org.apache.drill.exec.rpc
package org.apache.drill.exec.rpc
-
ClassDescriptionHelps to run a query and await on the results.AbstractHandshakeHandler<T extends com.google.protobuf.MessageLite>AbstractServerConnection<S extends ServerConnection<S>>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>Utility class providing common methods shared betweenDataClientandControlClientConnectionMultiListener<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>> Dynamic credit based flow control: The sender initially sends batch to the sender by the initial static credit (3).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> ListeningCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection, E extends com.google.protobuf.Internal.EnumLite, M extends com.google.protobuf.MessageLite> ThreadFactoryforExecutorServices that names threads sequentially.Modified version ofProtobufVarint32FrameDecoderthat avoids bytebuf copy.Manager all connections between two particular bits.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.Modified implementation of countdown latch that allows a barrier to be unilaterally opened and closed.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.RpcCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection, E extends com.google.protobuf.Internal.EnumLite, M extends com.google.protobuf.MessageLite> RpcConfig.RpcMessageType<SEND extends com.google.protobuf.MessageLite,RECEIVE extends com.google.protobuf.MessageLite, T extends com.google.protobuf.Internal.EnumLite> RpcConnectionHandler<T extends RemoteConnection>Parent class for all rpc exceptions.RpcExceptionHandler<C extends RemoteConnection>Holder interface for all the metrics used in RPC layerRpcOutcome<T>ServerConnection<S extends ServerConnection<S>>TransportCheck decides whether or not to use the native EPOLL mechanism for communication.Interface for getting user session properties and interacting with user connection.