|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.ipc.Client
public class Client
A client for an IPC service. IPC calls take a single Writable
as a
parameter, and return a Writable
as their value. A service runs on
a port and is defined by a parameter class and a value class.
Server
Field Summary | |
---|---|
static org.apache.commons.logging.Log |
LOG
|
Constructor Summary | |
---|---|
Client(Class valueClass,
Configuration conf)
Construct an IPC client whose values are of the given Writable
class. |
Method Summary | |
---|---|
Writable[] |
call(Writable[] params,
InetSocketAddress[] addresses)
Makes a set of calls in parallel. |
Writable |
call(Writable param,
InetSocketAddress address)
Make a call, passing param , to the IPC server running at
address , returning the value. |
void |
setTimeout(int timeout)
Sets the timeout used for network i/o. |
void |
stop()
Stop all threads related to this client. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final org.apache.commons.logging.Log LOG
Constructor Detail |
---|
public Client(Class valueClass, Configuration conf)
Writable
class.
Method Detail |
---|
public void stop()
public void setTimeout(int timeout)
public Writable call(Writable param, InetSocketAddress address) throws InterruptedException, IOException
param
, to the IPC server running at
address
, returning the value. Throws exceptions if there are
network problems or if the remote code threw an exception.
InterruptedException
IOException
public Writable[] call(Writable[] params, InetSocketAddress[] addresses) throws IOException
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |