org.apache.hadoop.ipc

类 RPC.Server

java.lang.Object

org.apache.hadoop.ipc.Server

org.apache.hadoop.ipc.RPC.Server

封闭类:

RPC

public static class RPC.Server
extends Server

An RPC Server.

嵌套类概要

从类继承的嵌套类/接口 org.apache.hadoop.ipc.Server

Server.Connection

字段概要

从类继承的字段 org.apache.hadoop.ipc.Server

CURRENT_VERSION, HEADER, LOG, rpcMetrics

构造器概要

构造器

构造器和说明
RPC.Server(Object instance, Configuration conf, String bindAddress, int port) Construct an RPC server.
RPC.Server(Object instance, Configuration conf, String bindAddress, int port, int numHandlers, boolean verbose, SecretManager<? extends TokenIdentifier> secretManager) Construct an RPC server.

方法概要

方法

限定符和类型	方法和说明
Writable	call(Class<?> protocol, Writable param, long receivedTime) Called for each call.

从类继承的方法 org.apache.hadoop.ipc.Server

addTerseExceptions, authorize, bind, call, get, getCallQueueLen, getListenerAddress, getNumOpenConnections, getRemoteAddress, getRemoteIp, getRpcMetrics, join, setSocketSendBufSize, start, stop

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

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

构造器详细资料

RPC.Server

public RPC.Server(Object instance,
          Configuration conf,
          String bindAddress,
          int port)
           throws IOException

Construct an RPC server.

参数:

instance - the instance whose methods will be called

conf - the configuration to use

bindAddress - the address to bind on to listen for connection

port - the port to listen for connections on

抛出:

IOException

RPC.Server

public RPC.Server(Object instance,
          Configuration conf,
          String bindAddress,
          int port,
          int numHandlers,
          boolean verbose,
          SecretManager<? extends TokenIdentifier> secretManager)
           throws IOException

Construct an RPC server.

参数:

instance - the instance whose methods will be called

conf - the configuration to use

bindAddress - the address to bind on to listen for connection

port - the port to listen for connections on

numHandlers - the number of method handler threads to run

verbose - whether each call should be logged

抛出:

IOException

方法详细资料

call

public Writable call(Class<?> protocol,
            Writable param,
            long receivedTime)
              throws IOException

从类复制的说明: Server

Called for each call.

指定者:

call 在类中 Server

抛出:

IOException