Uses of Interface
org.apache.hadoop.ipc.AlignmentContext
Packages that use AlignmentContext
Package
Description
Tools to help define network clients and servers.
Common utilities.
-
Uses of AlignmentContext in org.apache.hadoop.ipc
Methods in org.apache.hadoop.ipc with parameters of type AlignmentContextModifier and TypeMethodDescriptionClient.call(RPC.RpcKind rpcKind, Writable rpcRequest, Client.ConnectionId remoteId, AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext) static <T> ProtocolProxy<T>RPC.getProtocolProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext) Get a protocol proxy that contains a proxy connection to a remote server and a set of methods that are supported by the server.static <T> ProtocolProxy<T>RPC.getProtocolProxy(Class<T> protocol, long clientVersion, Client.ConnectionId connId, Configuration conf, SocketFactory factory, AlignmentContext alignmentContext) Get a protocol proxy that contains a proxy connection to a remote server and a set of methods that are supported by the server.<T> ProtocolProxy<T>ProtobufRpcEngine.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext) Deprecated.<T> ProtocolProxy<T>ProtobufRpcEngine.getProxy(Class<T> protocol, long clientVersion, Client.ConnectionId connId, Configuration conf, SocketFactory factory, AlignmentContext alignmentContext) Deprecated.<T> ProtocolProxy<T>ProtobufRpcEngine2.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext) <T> ProtocolProxy<T>ProtobufRpcEngine2.getProxy(Class<T> protocol, long clientVersion, Client.ConnectionId connId, Configuration conf, SocketFactory factory, AlignmentContext alignmentContext) <T> ProtocolProxy<T>RpcEngine.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext) Construct a client-side proxy object.<T> ProtocolProxy<T>RpcEngine.getProxy(Class<T> protocol, long clientVersion, Client.ConnectionId connId, Configuration conf, SocketFactory factory, AlignmentContext alignmentContext) Construct a client-side proxy object with a ConnectionId.<T> ProtocolProxy<T>WritableRpcEngine.getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext) Deprecated.Construct a client-side proxy object that implements the named protocol, talking to a server at the named address.<T> ProtocolProxy<T>WritableRpcEngine.getProxy(Class<T> protocol, long clientVersion, Client.ConnectionId connId, Configuration conf, SocketFactory factory, AlignmentContext alignmentContext) Deprecated.Construct a client-side proxy object with a ConnectionId.ProtobufRpcEngine.getServer(Class<?> protocol, Object protocolImpl, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, Configuration conf, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig, AlignmentContext alignmentContext) Deprecated.ProtobufRpcEngine2.getServer(Class<?> protocol, Object protocolImpl, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, Configuration conf, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig, AlignmentContext alignmentContext) RpcEngine.getServer(Class<?> protocol, Object instance, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, Configuration conf, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig, AlignmentContext alignmentContext) Construct a server for a protocol implementation instance.WritableRpcEngine.getServer(Class<?> protocolClass, Object protocolImpl, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, Configuration conf, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig, AlignmentContext alignmentContext) Deprecated.RPC.Builder.setAlignmentContext(AlignmentContext alignmentContext) voidServer.setAlignmentContext(AlignmentContext alignmentContext) Set alignment context to pass state info thru RPC.Constructors in org.apache.hadoop.ipc with parameters of type AlignmentContextModifierConstructorDescriptionprotectedInvoker(Class<?> protocol, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext) protectedInvoker(Class<?> protocol, Client.ConnectionId connId, Configuration conf, SocketFactory factory, AlignmentContext alignmentContext) This constructor takes a connectionId, instead of creating a new one.protectedInvoker(Class<?> protocol, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy, AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext) protectedInvoker(Class<?> protocol, Client.ConnectionId connId, Configuration conf, SocketFactory factory, AlignmentContext alignmentContext) This constructor takes a connectionId, instead of creating a new one.Server(Class<?> protocolClass, Object protocolImpl, Configuration conf, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig, AlignmentContext alignmentContext) Construct an RPC server.Server(Class<?> protocolClass, Object protocolImpl, Configuration conf, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig, AlignmentContext alignmentContext) Construct an RPC server.Server(Class<?> protocolClass, Object protocolImpl, Configuration conf, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig, AlignmentContext alignmentContext) Deprecated.Construct an RPC server. -
Uses of AlignmentContext in org.apache.hadoop.util
Methods in org.apache.hadoop.util with parameters of type AlignmentContextModifier and TypeMethodDescriptionstatic org.apache.hadoop.ipc.protobuf.RpcHeaderProtos.RpcRequestHeaderProtoProtoUtil.makeRpcRequestHeader(RPC.RpcKind rpcKind, org.apache.hadoop.ipc.protobuf.RpcHeaderProtos.RpcRequestHeaderProto.OperationProto operation, int callId, int retryCount, byte[] uuid, AlignmentContext alignmentContext)