Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
LOG |
Constructor and Description |
---|
Client(Class<? extends Writable> valueClass,
Configuration conf)
Construct an IPC client with the default SocketFactory
|
Client(Class<? extends Writable> valueClass,
Configuration conf,
SocketFactory factory)
Construct an IPC client whose values are of the given
Writable
class. |
Modifier and Type | Method and Description |
---|---|
Writable[] |
call(Writable[] params,
InetSocketAddress[] addresses)
Deprecated.
|
Writable[] |
call(Writable[] params,
InetSocketAddress[] addresses,
Class<?> protocol,
UserGroupInformation ticket)
Makes a set of calls in parallel.
|
Writable |
call(Writable param,
InetSocketAddress address)
Deprecated.
|
Writable |
call(Writable param,
InetSocketAddress addr,
Class<?> protocol,
UserGroupInformation ticket)
Make a call, passing
param , to the IPC server running at
address which is servicing the protocol protocol,
with the ticket credentials, returning the value. |
Writable |
call(Writable param,
InetSocketAddress addr,
UserGroupInformation ticket)
Deprecated.
|
static void |
setPingInterval(Configuration conf,
int pingInterval)
set the ping interval value in configuration
|
void |
stop()
Stop all threads related to this client.
|
public Client(Class<? extends Writable> valueClass, Configuration conf, SocketFactory factory)
Writable
class.public Client(Class<? extends Writable> valueClass, Configuration conf)
valueClass
- conf
- public static final void setPingInterval(Configuration conf, int pingInterval)
conf
- ConfigurationpingInterval
- the ping intervalpublic void stop()
@Deprecated public Writable call(Writable param, InetSocketAddress address) throws InterruptedException, IOException
call(Writable, InetSocketAddress, Class, UserGroupInformation)
insteadparam
, 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
@Deprecated public Writable call(Writable param, InetSocketAddress addr, UserGroupInformation ticket) throws InterruptedException, IOException
call(Writable, InetSocketAddress, Class, UserGroupInformation)
insteadparam
, to the IPC server running at
address
with the ticket
credentials, returning
the value.
Throws exceptions if there are network problems or if the remote code
threw an exception.InterruptedException
IOException
public Writable call(Writable param, InetSocketAddress addr, Class<?> protocol, UserGroupInformation ticket) throws InterruptedException, IOException
param
, to the IPC server running at
address
which is servicing the protocol
protocol,
with the ticket
credentials, returning the value.
Throws exceptions if there are network problems or if the remote code
threw an exception.InterruptedException
IOException
@Deprecated public Writable[] call(Writable[] params, InetSocketAddress[] addresses) throws IOException
call(Writable[], InetSocketAddress[], Class, UserGroupInformation)
insteadIOException
public Writable[] call(Writable[] params, InetSocketAddress[] addresses, Class<?> protocol, UserGroupInformation ticket) throws IOException
IOException
Copyright © 2010 The Apache Software Foundation