org.apache.hadoop.hbase.ipc
Class HBaseRPC.Server

java.lang.Object
  extended by org.apache.hadoop.hbase.ipc.HBaseServer
      extended by org.apache.hadoop.hbase.ipc.HBaseRPC.Server
Enclosing class:
HBaseRPC

public static class HBaseRPC.Server
extends HBaseServer

An RPC Server.


Field Summary
 
Fields inherited from class org.apache.hadoop.hbase.ipc.HBaseServer
bindAddress, callQueue, conf, connectionList, CurCall, CURRENT_VERSION, errorHandler, HEADER, LOG, maxIdleTime, numConnections, paramClass, port, priorityCallQueue, responder, rpcMetrics, running, SERVER, socketSendBufferSize, tcpKeepAlive, tcpNoDelay, thresholdIdleConnections
 
Constructor Summary
HBaseRPC.Server(Object instance, Class<?>[] ifaces, org.apache.hadoop.conf.Configuration conf, String bindAddress, int port, int numHandlers, int metaHandlerCount, boolean verbose, int highPriorityLevel)
          Construct an RPC server.
 
Method Summary
 org.apache.hadoop.io.Writable call(org.apache.hadoop.io.Writable param, long receivedTime)
          Called for each call.
 
Methods inherited from class org.apache.hadoop.hbase.ipc.HBaseServer
bind, channelRead, channelWrite, closeConnection, get, getCallQueueLen, getListenerAddress, getNumOpenConnections, getQosLevel, getRemoteAddress, getRemoteIp, getRpcMetrics, join, openServer, setErrorHandler, setQosFunction, setSocketSendBufSize, start, startThreads, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

HBaseRPC.Server

public HBaseRPC.Server(Object instance,
                       Class<?>[] ifaces,
                       org.apache.hadoop.conf.Configuration conf,
                       String bindAddress,
                       int port,
                       int numHandlers,
                       int metaHandlerCount,
                       boolean verbose,
                       int highPriorityLevel)
                throws IOException
Construct an RPC server.

Parameters:
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
Throws:
IOException - e
Method Detail

call

public org.apache.hadoop.io.Writable call(org.apache.hadoop.io.Writable param,
                                          long receivedTime)
                                   throws IOException
Description copied from class: HBaseServer
Called for each call.

Specified by:
call in class HBaseServer
Parameters:
param - writable parameter
receivedTime - time
Returns:
Writable
Throws:
IOException - e


Copyright © 2011 The Apache Software Foundation. All Rights Reserved.