@InterfaceStability.Evolving public class WritableRpcEngine extends Object implements RpcEngine
Modifier and Type | Class and Description |
---|---|
static class |
WritableRpcEngine.Server
An RPC Server.
|
Modifier and Type | Field and Description |
---|---|
static long |
writableRpcVersion |
Constructor and Description |
---|
WritableRpcEngine() |
Modifier and Type | Method and Description |
---|---|
static void |
ensureInitialized()
Initialize this class if it isn't already.
|
ProtocolProxy<ProtocolMetaInfoPB> |
getProtocolMetaInfoProxy(Client.ConnectionId connId,
Configuration conf,
SocketFactory factory)
Returns a proxy for ProtocolMetaInfoPB, which uses the given connection
id.
|
<T> ProtocolProxy<T> |
getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy)
Construct a client-side proxy object that implements the named protocol,
talking to a server at the named address.
|
RPC.Server |
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)
Construct a server for a protocol implementation instance.
|
public static final long writableRpcVersion
public static void ensureInitialized()
public <T> ProtocolProxy<T> getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy) throws IOException
getProxy
in interface RpcEngine
T
- IOException
public RPC.Server 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) throws IOException
RpcEngine
getServer
in interface RpcEngine
protocolClass
- the class of protocol to useprotocolImpl
- the instance of protocol whose methods will be calledbindAddress
- the address to bind on to listen for connectionport
- the port to listen for connections onnumHandlers
- the number of method handler threads to runnumReaders
- the number of reader threads to runqueueSizePerHandler
- the size of the queue per hander threadverbose
- whether each call should be loggedconf
- the configuration to usesecretManager
- The secret manager to use to validate incoming requests.portRangeConfig
- A config parameter that can be used to restrict
the range of ports used when port is 0 (an ephemeral port)IOException
- on any errorpublic ProtocolProxy<ProtocolMetaInfoPB> getProtocolMetaInfoProxy(Client.ConnectionId connId, Configuration conf, SocketFactory factory) throws IOException
RpcEngine
getProtocolMetaInfoProxy
in interface RpcEngine
IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.