Package | Description |
---|---|
org.apache.hadoop.hbase.ipc |
Tools to help define network clients and servers.
|
org.apache.hadoop.hbase.regionserver |
Modifier and Type | Interface and Description |
---|---|
interface |
RpcCall
Interface of all necessary to carry out a RPC method invocation on the server.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
NettyServerCall
Datastructure that holds all necessary to a method invocation and then afterward, carries the
result.
|
class |
ServerCall<T extends ServerRpcConnection>
Datastructure that holds all necessary to a method invocation and then afterward, carries
the result.
|
(package private) class |
SimpleServerCall
Datastructure that holds all necessary to a method invocation and then afterward, carries the
result.
|
Modifier and Type | Method and Description |
---|---|
(package private) Object |
RSRpcServices.addSize(RpcCallContext context,
Result r,
Object lastBlock)
Method to account for the size of retained cells and retained data blocks.
|
private void |
RSRpcServices.closeScanner(HRegion region,
RegionScanner scanner,
String scannerName,
RpcCallContext context) |
private List<CellScannable> |
RSRpcServices.doNonAtomicRegionMutation(HRegion region,
OperationQuota quota,
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionAction actions,
CellScanner cellScanner,
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder,
List<CellScannable> cellsToReturn,
long nonceGroup,
RSRpcServices.RegionScannersCloseCallBack closeCallBack,
RpcCallContext context,
ActivePolicyEnforcement spaceQuotaEnforcement)
Run through the regionMutation
rm and per Mutation, do the work, and then when
done, add an instance of a ClientProtos.ResultOrException that corresponds to each Mutation. |
private Result |
RSRpcServices.get(Get get,
HRegion region,
RSRpcServices.RegionScannersCloseCallBack closeCallBack,
RpcCallContext context) |
private boolean |
RSRpcServices.isClientCellBlockSupport(RpcCallContext context) |
private void |
RSRpcServices.scan(HBaseRpcController controller,
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request,
RSRpcServices.RegionScannerHolder rsh,
long maxQuotaResultSize,
int maxResults,
int limitOfRows,
List<Result> results,
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse.Builder builder,
org.apache.commons.lang3.mutable.MutableObject<Object> lastBlock,
RpcCallContext context) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.