Class Hierarchy
- java.lang.Object
- org.apache.drill.exec.rpc.AbstractConnectionConfig (implements org.apache.drill.exec.rpc.ConnectionConfig)
- org.apache.drill.exec.rpc.BitConnectionConfig
- org.apache.drill.exec.rpc.AbstractDisposableUserClientConnection (implements org.apache.drill.exec.rpc.UserClientConnection)
- org.apache.drill.exec.rpc.AbstractRemoteConnection (implements org.apache.drill.exec.rpc.EncryptionContext, org.apache.drill.exec.rpc.RemoteConnection)
- org.apache.drill.exec.rpc.AbstractClientConnection (implements org.apache.drill.exec.rpc.ClientConnection)
- org.apache.drill.exec.rpc.AbstractServerConnection<S> (implements org.apache.drill.exec.rpc.ServerConnection<S>)
- org.apache.drill.exec.rpc.AbstractRpcMetrics (implements org.apache.drill.exec.rpc.RpcMetrics)
- org.apache.drill.exec.rpc.Acks
- org.apache.drill.exec.rpc.BaseRpcOutcomeListener<T> (implements org.apache.drill.exec.rpc.RpcOutcomeListener<V>)
- org.apache.drill.exec.rpc.BitRpcUtility
- io.netty.channel.ChannelHandlerAdapter (implements io.netty.channel.ChannelHandler)
- io.netty.channel.ChannelInboundHandlerAdapter (implements io.netty.channel.ChannelInboundHandler)
- io.netty.handler.codec.ByteToMessageDecoder
- org.apache.drill.exec.rpc.ProtobufLengthDecoder
- io.netty.handler.codec.MessageToMessageDecoder<I>
- org.apache.drill.exec.rpc.AbstractHandshakeHandler<T>
- org.apache.drill.exec.rpc.BasicServer.ServerHandshakeHandler<T>
- org.apache.drill.exec.rpc.RpcBus.InboundHandler
- org.apache.drill.exec.rpc.AbstractHandshakeHandler<T>
- io.netty.handler.codec.ByteToMessageDecoder
- io.netty.channel.ChannelInboundHandlerAdapter (implements io.netty.channel.ChannelInboundHandler)
- org.apache.drill.exec.rpc.ConnectionMultiListener<T,
CC, HS, HR, BC> - org.apache.drill.exec.rpc.ConnectionMultiListener.Builder<T,
CC, HS, HR, BC> - org.apache.drill.exec.rpc.ConnectionMultiListener.SSLHandshakeListener (implements io.netty.util.concurrent.GenericFutureListener<F>)
- org.apache.drill.exec.rpc.DynamicSemaphore
- org.apache.drill.exec.rpc.EncryptionContextImpl (implements org.apache.drill.exec.rpc.EncryptionContext)
- org.apache.drill.exec.rpc.FailingRequestHandler<S> (implements org.apache.drill.exec.rpc.RequestHandler<S>)
- org.apache.drill.shaded.guava.com.google.common.collect.ForwardingObject
- org.apache.drill.shaded.guava.com.google.common.util.concurrent.ForwardingFuture<V> (implements java.util.concurrent.Future<V>)
- org.apache.drill.shaded.guava.com.google.common.util.concurrent.ForwardingListenableFuture<V> (implements org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture<V>)
- org.apache.drill.shaded.guava.com.google.common.util.concurrent.ForwardingListenableFuture.SimpleForwardingListenableFuture<V>
- org.apache.drill.common.concurrent.AbstractCheckedFuture<T,
E> (implements org.apache.drill.common.concurrent.CheckedFuture<V, X>) - org.apache.drill.exec.rpc.RpcCheckedFuture<T> (implements org.apache.drill.exec.rpc.DrillRpcFuture<T>)
- org.apache.drill.common.concurrent.AbstractCheckedFuture<T,
- org.apache.drill.shaded.guava.com.google.common.util.concurrent.ForwardingListenableFuture.SimpleForwardingListenableFuture<V>
- org.apache.drill.shaded.guava.com.google.common.util.concurrent.ForwardingListenableFuture<V> (implements org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture<V>)
- org.apache.drill.shaded.guava.com.google.common.util.concurrent.ForwardingFuture<V> (implements java.util.concurrent.Future<V>)
- org.apache.drill.exec.rpc.FutureBitCommand<T,
C, E, M> (implements org.apache.drill.exec.rpc.RpcCommand<T, C, E, M>) - org.apache.drill.shaded.guava.com.google.common.util.concurrent.internal.InternalFutureFailureAccess
- org.apache.drill.shaded.guava.com.google.common.util.concurrent.AbstractFuture<V> (implements org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture<V>)
- org.apache.drill.exec.rpc.ReconnectingConnection.ConnectionListeningFuture<R,
E, M> (implements org.apache.drill.exec.rpc.RpcConnectionHandler<T>)
- org.apache.drill.exec.rpc.ReconnectingConnection.ConnectionListeningFuture<R,
- org.apache.drill.shaded.guava.com.google.common.util.concurrent.AbstractFuture<V> (implements org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture<V>)
- org.apache.drill.exec.rpc.ListeningCommand<T,
C, E, M> (implements org.apache.drill.exec.rpc.RpcCommand<T, C, E, M>) - org.apache.drill.exec.rpc.NamedThreadFactory (implements java.util.concurrent.ThreadFactory)
- org.apache.drill.exec.rpc.ReconnectingConnection<C,
HS> (implements java.io.Closeable) - org.apache.drill.exec.rpc.ReconnectingConnection.CloseHandler (implements io.netty.util.concurrent.GenericFutureListener<F>)
- org.apache.drill.exec.rpc.ReconnectingConnection.CloseHandlerCreator
- org.apache.drill.exec.rpc.ResettableBarrier
- org.apache.drill.exec.rpc.Response
- org.apache.drill.exec.rpc.RpcBus<T,
C> (implements java.io.Closeable) - org.apache.drill.exec.rpc.BasicClient<T,
CC, HS, HR> - org.apache.drill.exec.rpc.BasicServer<T,
SC>
- org.apache.drill.exec.rpc.BasicClient<T,
- org.apache.drill.exec.rpc.RpcBus.ChannelClosedHandler (implements io.netty.util.concurrent.GenericFutureListener<F>)
- org.apache.drill.exec.rpc.RpcConfig
- org.apache.drill.exec.rpc.RpcConfig.RpcConfigBuilder
- org.apache.drill.exec.rpc.RpcConfig.RpcMessageType<SEND,
RECEIVE, T> - org.apache.drill.exec.rpc.RpcConstants
- org.apache.drill.exec.rpc.RpcExceptionHandler<C> (implements io.netty.channel.ChannelHandler)
- org.apache.drill.exec.rpc.RpcMessage
- org.apache.drill.exec.rpc.InboundRpcMessage
- org.apache.drill.exec.rpc.OutboundRpcMessage
- java.lang.Throwable (implements java.io.Serializable)
- java.lang.Exception
- java.io.IOException
- org.apache.drill.common.exceptions.DrillIOException
- org.apache.drill.exec.rpc.RpcException
- org.apache.drill.exec.rpc.ChannelClosedException
- org.apache.drill.exec.rpc.NonTransientRpcException
- org.apache.drill.exec.rpc.UserRpcException
- org.apache.drill.exec.rpc.RpcException
- org.apache.drill.common.exceptions.DrillIOException
- java.io.IOException
- java.lang.Exception
- org.apache.drill.exec.rpc.TransportCheck
- org.apache.drill.exec.rpc.AbstractConnectionConfig (implements org.apache.drill.exec.rpc.ConnectionConfig)
Interface Hierarchy
- java.lang.AutoCloseable
- org.apache.drill.exec.rpc.RemoteConnection (also extends org.apache.drill.exec.rpc.ConnectionThrottle)
- org.apache.drill.exec.rpc.ClientConnection (also extends org.apache.drill.exec.rpc.EncryptionContext)
- org.apache.drill.exec.rpc.ServerConnection<S> (also extends org.apache.drill.exec.rpc.EncryptionContext)
- org.apache.drill.exec.rpc.RemoteConnection (also extends org.apache.drill.exec.rpc.ConnectionThrottle)
- org.apache.drill.exec.rpc.ConnectionConfig
- org.apache.drill.exec.rpc.ConnectionThrottle
- org.apache.drill.exec.rpc.RemoteConnection (also extends java.lang.AutoCloseable)
- org.apache.drill.exec.rpc.ClientConnection (also extends org.apache.drill.exec.rpc.EncryptionContext)
- org.apache.drill.exec.rpc.ServerConnection<S> (also extends org.apache.drill.exec.rpc.EncryptionContext)
- org.apache.drill.exec.rpc.RemoteConnection (also extends java.lang.AutoCloseable)
- org.apache.drill.exec.rpc.EncryptionContext
- org.apache.drill.exec.rpc.ClientConnection (also extends org.apache.drill.exec.rpc.RemoteConnection)
- org.apache.drill.exec.rpc.ServerConnection<S> (also extends org.apache.drill.exec.rpc.RemoteConnection)
- java.util.EventListener
- io.netty.util.concurrent.GenericFutureListener<F>
- org.apache.drill.exec.rpc.ChannelListenerWithCoordinationId
- io.netty.util.concurrent.GenericFutureListener<F>
- java.util.concurrent.Future<V>
- org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture<V>
- org.apache.drill.common.concurrent.CheckedFuture<V,
X> - org.apache.drill.exec.rpc.DrillRpcFuture<T>
- org.apache.drill.common.concurrent.CheckedFuture<V,
- org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture<V>
- org.apache.drill.exec.rpc.OutOfMemoryHandler
- org.apache.drill.exec.rpc.RequestHandler<S>
- org.apache.drill.exec.rpc.ResponseSender
- org.apache.drill.exec.rpc.RpcConnectionHandler<T>
- org.apache.drill.exec.rpc.RpcCommand<T,
C, E, M>
- org.apache.drill.exec.rpc.RpcCommand<T,
- org.apache.drill.exec.rpc.RpcMetrics
- org.apache.drill.exec.rpc.RpcOutcome<T>
- org.apache.drill.exec.rpc.RpcOutcomeListener<V>
- org.apache.drill.exec.rpc.SaslCodec
- org.apache.drill.exec.rpc.UserClientConnection
Enum Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
- org.apache.drill.exec.rpc.RpcConnectionHandler.FailureType
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)