|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.ipc.RPC
public class RPC
A simple RPC mechanism. A protocol is a Java interface. All parameters and return types must be one of:
boolean
, byte
,
char
, short
, int
, long
,
float
, double
, or void
; orString
; orWritable
; or
Nested Class Summary | |
---|---|
static class |
RPC.Server
An RPC Server. |
static class |
RPC.VersionMismatch
A version mismatch for the RPC protocol. |
Method Summary | |
---|---|
static Object[] |
call(Method method,
Object[][] params,
InetSocketAddress[] addrs,
Configuration conf)
Deprecated. Use call(Method, Object[][], InetSocketAddress[], UserGroupInformation, Configuration) instead |
static Object[] |
call(Method method,
Object[][] params,
InetSocketAddress[] addrs,
UserGroupInformation ticket,
Configuration conf)
Expert: Make multiple, parallel calls to a set of servers. |
static VersionedProtocol |
getProxy(Class<? extends VersionedProtocol> protocol,
long clientVersion,
InetSocketAddress addr,
Configuration conf)
Construct a client-side proxy object with the default SocketFactory |
static VersionedProtocol |
getProxy(Class<? extends VersionedProtocol> protocol,
long clientVersion,
InetSocketAddress addr,
Configuration conf,
int rpcTimeout)
|
static VersionedProtocol |
getProxy(Class<? extends VersionedProtocol> protocol,
long clientVersion,
InetSocketAddress addr,
Configuration conf,
SocketFactory factory)
Construct a client-side proxy object that implements the named protocol, talking to a server at the named address. |
static VersionedProtocol |
getProxy(Class<? extends VersionedProtocol> protocol,
long clientVersion,
InetSocketAddress addr,
Configuration conf,
SocketFactory factory,
int rpcTimeout)
Construct a client-side proxy object that implements the named protocol, talking to a server at the named address. |
static VersionedProtocol |
getProxy(Class<? extends VersionedProtocol> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory)
Construct a client-side proxy object that implements the named protocol, talking to a server at the named address. |
static VersionedProtocol |
getProxy(Class<? extends VersionedProtocol> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout)
Construct a client-side proxy object that implements the named protocol, talking to a server at the named address. |
static RPC.Server |
getServer(Object instance,
String bindAddress,
int port,
Configuration conf)
Construct a server for a protocol implementation instance listening on a port and address. |
static RPC.Server |
getServer(Object instance,
String bindAddress,
int port,
int numHandlers,
boolean verbose,
Configuration conf)
Construct a server for a protocol implementation instance listening on a port and address. |
static RPC.Server |
getServer(Object instance,
String bindAddress,
int port,
int numHandlers,
boolean verbose,
Configuration conf,
SecretManager<? extends TokenIdentifier> secretManager)
Construct a server for a protocol implementation instance listening on a port and address, with a secret manager. |
static void |
stopProxy(VersionedProtocol proxy)
Stop this proxy and release its invoker's resource |
static VersionedProtocol |
waitForProxy(Class<? extends VersionedProtocol> protocol,
long clientVersion,
InetSocketAddress addr,
Configuration conf)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Method Detail |
---|
public static VersionedProtocol waitForProxy(Class<? extends VersionedProtocol> protocol, long clientVersion, InetSocketAddress addr, Configuration conf) throws IOException
IOException
public static VersionedProtocol getProxy(Class<? extends VersionedProtocol> protocol, long clientVersion, InetSocketAddress addr, Configuration conf, SocketFactory factory) throws IOException
IOException
public static VersionedProtocol getProxy(Class<? extends VersionedProtocol> protocol, long clientVersion, InetSocketAddress addr, Configuration conf, SocketFactory factory, int rpcTimeout) throws IOException
IOException
public static VersionedProtocol getProxy(Class<? extends VersionedProtocol> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory) throws IOException
IOException
public static VersionedProtocol getProxy(Class<? extends VersionedProtocol> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout) throws IOException
IOException
public static VersionedProtocol getProxy(Class<? extends VersionedProtocol> protocol, long clientVersion, InetSocketAddress addr, Configuration conf) throws IOException
protocol
- clientVersion
- addr
- conf
-
IOException
public static VersionedProtocol getProxy(Class<? extends VersionedProtocol> protocol, long clientVersion, InetSocketAddress addr, Configuration conf, int rpcTimeout) throws IOException
IOException
public static void stopProxy(VersionedProtocol proxy)
proxy
- the proxy to be stoppedpublic static Object[] call(Method method, Object[][] params, InetSocketAddress[] addrs, Configuration conf) throws IOException, InterruptedException
call(Method, Object[][], InetSocketAddress[], UserGroupInformation, Configuration)
instead
IOException
InterruptedException
public static Object[] call(Method method, Object[][] params, InetSocketAddress[] addrs, UserGroupInformation ticket, Configuration conf) throws IOException, InterruptedException
IOException
InterruptedException
public static RPC.Server getServer(Object instance, String bindAddress, int port, Configuration conf) throws IOException
IOException
public static RPC.Server getServer(Object instance, String bindAddress, int port, int numHandlers, boolean verbose, Configuration conf) throws IOException
IOException
public static RPC.Server getServer(Object instance, String bindAddress, int port, int numHandlers, boolean verbose, Configuration conf, SecretManager<? extends TokenIdentifier> secretManager) throws IOException
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |