org.apache.hadoop.ipc

类 Client

java.lang.Object

org.apache.hadoop.ipc.Client

public class Client
extends Object

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

字段概要

字段

限定符和类型	字段和说明
static int	IPC_CLIENT_CONNECT_MAX_RETRIES_DEFAULT
static String	IPC_CLIENT_CONNECT_MAX_RETRIES_KEY
static org.apache.commons.logging.Log	LOG

构造器概要

构造器

构造器和说明
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.

方法概要

方法

限定符和类型	方法和说明
Writable[]	call(Writable[] params, InetSocketAddress[] addresses) 已过时。 Use call(Writable[], InetSocketAddress[], Class, UserGroupInformation, Configuration) instead
Writable[]	call(Writable[] params, InetSocketAddress[] addresses, Class<?> protocol, UserGroupInformation ticket) 已过时。 Use call(Writable[], InetSocketAddress[], Class, UserGroupInformation, Configuration) instead
Writable[]	call(Writable[] params, InetSocketAddress[] addresses, Class<?> protocol, UserGroupInformation ticket, Configuration conf) Makes a set of calls in parallel.
Writable	call(Writable param, org.apache.hadoop.ipc.Client.ConnectionId remoteId) Make a call, passing param, to the IPC server defined by remoteId, returning the value.
Writable	call(Writable param, InetSocketAddress address) 已过时。 Use call(Writable, ConnectionId) instead
Writable	call(Writable param, InetSocketAddress addr, Class<?> protocol, UserGroupInformation ticket, int rpcTimeout) 已过时。 Use call(Writable, ConnectionId) instead
Writable	call(Writable param, InetSocketAddress addr, Class<?> protocol, UserGroupInformation ticket, int rpcTimeout, Configuration conf) Make a call, passing param, to the IPC server running at address which is servicing the protocol protocol, with the ticket credentials, rpcTimeout as timeout and conf as configuration for this connection, returning the value.
Writable	call(Writable param, InetSocketAddress addr, UserGroupInformation ticket) 已过时。 Use call(Writable, ConnectionId) instead
static int	getTimeout(Configuration conf) The time after which a RPC will timeout.
static void	setPingInterval(Configuration conf, int pingInterval) set the ping interval value in configuration
void	stop() Stop all threads related to this client.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

IPC_CLIENT_CONNECT_MAX_RETRIES_KEY

public static final String IPC_CLIENT_CONNECT_MAX_RETRIES_KEY

另请参阅:

常量字段值

IPC_CLIENT_CONNECT_MAX_RETRIES_DEFAULT

public static final int IPC_CLIENT_CONNECT_MAX_RETRIES_DEFAULT

另请参阅:

常量字段值

LOG

public static final org.apache.commons.logging.Log LOG

构造器详细资料

Client

public Client(Class<? extends Writable> valueClass,
      Configuration conf,
      SocketFactory factory)

Construct an IPC client whose values are of the given Writable class.

Client

public Client(Class<? extends Writable> valueClass,
      Configuration conf)

Construct an IPC client with the default SocketFactory

参数:

valueClass -

conf -

方法详细资料

setPingInterval

public static final void setPingInterval(Configuration conf,
                   int pingInterval)

set the ping interval value in configuration

参数:

conf - Configuration

pingInterval - the ping interval

getTimeout

public static final int getTimeout(Configuration conf)

The time after which a RPC will timeout. If ping is not enabled (via ipc.client.ping), then the timeout value is the same as the pingInterval. If ping is enabled, then there is no timeout value.

参数:

conf - Configuration

返回:

the timeout period in milliseconds. -1 if no timeout value is set

stop

public void stop()

Stop all threads related to this client. No further calls may be made using this client.

call

@Deprecated
public Writable call(Writable param,
                       InetSocketAddress address)
              throws InterruptedException,
                     IOException

已过时。 Use call(Writable, ConnectionId) instead

Make a call, passing 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

call

@Deprecated
public Writable call(Writable param,
                       InetSocketAddress addr,
                       UserGroupInformation ticket)
              throws InterruptedException,
                     IOException

已过时。 Use call(Writable, ConnectionId) instead

Make a call, passing param, 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

call

@Deprecated
public Writable call(Writable param,
                       InetSocketAddress addr,
                       Class<?> protocol,
                       UserGroupInformation ticket,
                       int rpcTimeout)
              throws InterruptedException,
                     IOException

已过时。 Use call(Writable, ConnectionId) instead

Make a call, passing param, to the IPC server running at address which is servicing the protocol protocol, with the ticket credentials and rpcTimeout as timeout, returning the value. Throws exceptions if there are network problems or if the remote code threw an exception.

抛出:

InterruptedException

IOException

call

public Writable call(Writable param,
            InetSocketAddress addr,
            Class<?> protocol,
            UserGroupInformation ticket,
            int rpcTimeout,
            Configuration conf)
              throws InterruptedException,
                     IOException

Make a call, passing param, to the IPC server running at address which is servicing the protocol protocol, with the ticket credentials, rpcTimeout as timeout and conf as configuration for this connection, returning the value. Throws exceptions if there are network problems or if the remote code threw an exception.

抛出:

InterruptedException

IOException

call

public Writable call(Writable param,
            org.apache.hadoop.ipc.Client.ConnectionId remoteId)
              throws InterruptedException,
                     IOException

Make a call, passing param, to the IPC server defined by remoteId, returning the value. Throws exceptions if there are network problems or if the remote code threw an exception.

抛出:

InterruptedException

IOException

call

@Deprecated
public Writable[] call(Writable[] params,
                         InetSocketAddress[] addresses)
                throws IOException,
                       InterruptedException

已过时。 Use call(Writable[], InetSocketAddress[], Class, UserGroupInformation, Configuration) instead

抛出:

IOException

InterruptedException

call

@Deprecated
public Writable[] call(Writable[] params,
                         InetSocketAddress[] addresses,
                         Class<?> protocol,
                         UserGroupInformation ticket)
                throws IOException,
                       InterruptedException

已过时。 Use call(Writable[], InetSocketAddress[], Class, UserGroupInformation, Configuration) instead

抛出:

IOException

InterruptedException

call

public Writable[] call(Writable[] params,
              InetSocketAddress[] addresses,
              Class<?> protocol,
              UserGroupInformation ticket,
              Configuration conf)
                throws IOException,
                       InterruptedException

Makes a set of calls in parallel. Each parameter is sent to the corresponding address. When all values are available, or have timed out or errored, the collected results are returned in an array. The array contains nulls for calls that timed out or errored.

抛出:

IOException

InterruptedException