Package org.apache.hadoop.ipc
@LimitedPrivate({"HBase","HDFS","MapReduce","YARN","Hive","Ozone"})
@Evolving
package org.apache.hadoop.ipc
-
ClassDescriptionThis interface intends to align the state between client and server via RPC communication.Signals that an AsyncCallLimitExceededException has occurred.A class defining the caller context for auditing coarse granularity operations.The caller context builder.CallQueueManager<E extends Schedulable>Abstracts queue operations for different blocking queues.A client for an IPC service.This class holds the address and the user ticket.Manages the input and output streams for an IPC connection.A class defining a set of static helper methods to provide conversion between bytes and string for UUID-based client Id.Used by
DecayRpcSchedulerto get the cost of users' operations.The decay RPC scheduler tracks the cost of incoming requests in a map, then decays the costs at a fixed time interval.This TimerTask will call decayCurrentCosts until the scheduler has been garbage collected.MetricsProxy is a singleton because we may init multiple schedulers and we want to clean up resources when a new scheduler replaces the old one.Provides metrics for Decay scheduler.Ignores process details and returns a constant value for each call.No op default RPC scheduler.ExternalCall<T>FairCallQueue<E extends Schedulable>A queue with multiple levels for each priority.Protocol which is used to refresh arbitrary things at runtime.The IdentityProvider creates identities for each schedulable by extracting fields and returning an identity string.IPC exception is thrown by IPC layer when the IPC connection cannot be established.Thrown by a remote ObserverNode indicating the operation has failed and the client should retry active namenode directly (instead of retry other ObserverNodes).Stores the times that a call takes to be processed through each step and its response status.The different stages to track the time of.Deprecated.Deprecated.Server implementation is always ProtobufRpcEngine2 based implementation, supports backward compatibility for protobuf 2.5 based implementations, which uses non-shaded protobuf classes.RPC Engine for for protobuf based RPCs.Deprecated.A RpcWritable wrapper for unshaded protobuf messages.The protocol name that is used when a client and server connect.Protocol to get versions and signatures for supported protocols from the server.This class serves the requests for protocol versions and signatures by looking them up in the server registry.This interface is implemented by the client side translators and can be used to obtain information about underlying protocol e.g. to check if a method is supported on the server side.a class wraps around a server's proxy, containing a list of its supported methods.An interface implemented by client-side protocol translators to get the underlying proxy object the translator is operating on.A utility class used to combine two protocol proxies.Protocol which is used to refresh the call queue in use currently.Used to registry custom methods to refresh at runtime.Used to registry custom methods to refresh at runtime.Return a response in the handler method for the user to see.Exception thrown by a server typically to indicate that server is in a state where request cannot be processed temporarily (such as still starting up).Maintains a cache of non-idempotent requests that have been successfully processed by the RPC server implementation, to handle the retries.CacheEntry is tracked using unique client ID and callId of the RPC request.CacheEntry with payload that tracks the previous response or parts of previous response to be used for generating response for retried requests.A simple RPC mechanism.Class to construct instances of RPC server with specific options.An RPC Server.A version mismatch for the RPC protocol.Indicates an exception in the RPC clientThis class maintains a cache of protocol versions and corresponding protocol signatures, keyed by server address, protocol and rpc kind.An RPC implementation.Indicates an exception during the execution of remote procedure call.This interface must be implemented by all InvocationHandler implementations.Implement this interface to make a pluggable multiplexer in the FairCallQueue.No such Method for an Rpc CallNo such protocol (i.e. interface) for and Rpc CallImplement this interface to be used for RPC scheduling and backoff.Indicates an exception on the RPC serveradapter to allow decoding of writables and protobufs from a byte buffer.Interface which allows extracting information necessary to create schedulable identity strings.An abstract IPC service.A generic call queued for handling.Thrown by a remote server when it is up, but is not the active server in a set of servers in which only a subset may be active.Indicates that the RPC server encountered an undeclared exception from the serviceThe UserIdentityProvider creates uses the username as the identity.Superclass of all protocols that use Hadoop RPC.Determines which queue to start reading from, occasionally drawing from low-priority queues in order to prevent starvation.ACostProviderthat calculates the cost for an operation as a weighted sum of its processing time values (seeProcessingDetails).Deprecated.Deprecated.
ShadedProtobufHelper.