@InterfaceAudience.Private public interface RpcServerInterface
Modifier and Type | Method and Description |
---|---|
void |
addCallSize(long diff)
Add/subtract from the current size of all outstanding calls.
|
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hbase.thirdparty.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<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
MonitoredRPCHandler status,
long startTime,
int timeout)
Deprecated.
As of release 2.0, this will be removed in HBase 3.0
|
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
call(RpcCall call,
MonitoredRPCHandler status) |
ByteBuffAllocator |
getByteBuffAllocator()
Allocator to allocate/free the ByteBuffers, those ByteBuffers can be on-heap or off-heap.
|
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.conf.Configuration conf,
org.apache.hadoop.security.authorize.PolicyProvider pp)
Refresh authentication manager policy.
|
void |
setErrorHandler(HBaseRPCErrorHandler handler) |
void |
setNamedQueueRecorder(NamedQueueRecorder namedQueueRecorder)
Set Online SlowLog Provider
|
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<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service, org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, org.apache.hbase.thirdparty.com.google.protobuf.Message param, CellScanner cellScanner, long receiveTime, MonitoredRPCHandler status) throws IOException
IOException
@Deprecated Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service, org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, org.apache.hbase.thirdparty.com.google.protobuf.Message param, CellScanner cellScanner, long receiveTime, MonitoredRPCHandler status, long startTime, int timeout) throws IOException
IOException
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> call(RpcCall call, MonitoredRPCHandler status) throws IOException
IOException
void setErrorHandler(HBaseRPCErrorHandler handler)
HBaseRPCErrorHandler getErrorHandler()
MetricsHBaseServer getMetrics()
void addCallSize(long diff)
diff
- Change (plus or minus)void refreshAuthManager(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.authorize.PolicyProvider pp)
RpcScheduler getScheduler()
ByteBuffAllocator getByteBuffAllocator()
void setRsRpcServices(RSRpcServices rsRpcServices)
void setNamedQueueRecorder(NamedQueueRecorder namedQueueRecorder)
namedQueueRecorder
- instance of NamedQueueRecorder
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.