Hierarchy For Package org.apache.drill.exec.rpc

Package Hierarchies:

• All Packages

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.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.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.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.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.TransportCheck

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.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.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
• 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.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.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