org.apache.hadoop.hbase.ipc
Class HBaseRPC.Server
java.lang.Object
org.apache.hadoop.hbase.ipc.HBaseServer
org.apache.hadoop.hbase.ipc.HBaseRPC.Server
- Enclosing class:
- HBaseRPC
public static class HBaseRPC.Server
- extends HBaseServer
An RPC Server.
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 |
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 calledconf
- the configuration to usebindAddress
- the address to bind on to listen for connectionport
- the port to listen for connections onnumHandlers
- the number of method handler threads to runverbose
- whether each call should be logged
- Throws:
IOException
- e
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 parameterreceivedTime
- time
- Returns:
- Writable
- Throws:
IOException
- e
Copyright © 2011 The Apache Software Foundation. All Rights Reserved.