@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"}) @InterfaceStability.Evolving public interface RpcServerInterface
Modifier and Type | Method and Description |
---|---|
void |
addCallSize(long diff)
Add/subtract from the current size of all outstanding calls.
|
Pair<com.google.protobuf.Message,CellScanner> |
call(com.google.protobuf.BlockingService service,
com.google.protobuf.Descriptors.MethodDescriptor md,
com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
MonitoredRPCHandler status)
Deprecated.
As of release 1.3, this will be removed in HBase 3.0
|
Pair<com.google.protobuf.Message,CellScanner> |
call(com.google.protobuf.BlockingService service,
com.google.protobuf.Descriptors.MethodDescriptor md,
com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
MonitoredRPCHandler status,
long startTime,
int timeout) |
HBaseRPCErrorHandler |
getErrorHandler() |
InetSocketAddress |
getListenerAddress() |
MetricsHBaseServer |
getMetrics()
Returns the metrics instance for reporting RPC call statistics
|
RpcScheduler |
getScheduler() |
boolean |
isStarted() |
void |
join() |
void |
refreshAuthManager(org.apache.hadoop.security.authorize.PolicyProvider pp)
Refresh authentication manager policy.
|
void |
setErrorHandler(HBaseRPCErrorHandler handler) |
void |
setRsRpcServices(RSRpcServices rsRpcServices) |
void |
setSocketSendBufSize(int size) |
void |
start() |
void |
stop() |
void start()
boolean isStarted()
void stop()
void join() throws InterruptedException
InterruptedException
void setSocketSendBufSize(int size)
InetSocketAddress getListenerAddress()
@Deprecated Pair<com.google.protobuf.Message,CellScanner> call(com.google.protobuf.BlockingService service, com.google.protobuf.Descriptors.MethodDescriptor md, com.google.protobuf.Message param, CellScanner cellScanner, long receiveTime, MonitoredRPCHandler status) throws IOException, com.google.protobuf.ServiceException
IOException
com.google.protobuf.ServiceException
Pair<com.google.protobuf.Message,CellScanner> call(com.google.protobuf.BlockingService service, com.google.protobuf.Descriptors.MethodDescriptor md, com.google.protobuf.Message param, CellScanner cellScanner, long receiveTime, MonitoredRPCHandler status, long startTime, int timeout) throws IOException, com.google.protobuf.ServiceException
IOException
com.google.protobuf.ServiceException
void setErrorHandler(HBaseRPCErrorHandler handler)
HBaseRPCErrorHandler getErrorHandler()
MetricsHBaseServer getMetrics()
void addCallSize(long diff)
diff
- Change (plus or minus)void refreshAuthManager(org.apache.hadoop.security.authorize.PolicyProvider pp)
pp
- RpcScheduler getScheduler()
void setRsRpcServices(RSRpcServices rsRpcServices)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.