Package | Description |
---|---|
org.apache.hadoop.hbase.regionserver |
Modifier and Type | Field and Description |
---|---|
private ConcurrentMap<String,RSRpcServices.RegionScannerHolder> |
RSRpcServices.scanners |
Modifier and Type | Method and Description |
---|---|
private RSRpcServices.RegionScannerHolder |
RSRpcServices.addScanner(String scannerName,
RegionScanner s,
Shipper shipper,
HRegion r,
boolean needCursor,
boolean fullRegionScan) |
private RSRpcServices.RegionScannerHolder |
RSRpcServices.getRegionScanner(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request) |
private RSRpcServices.RegionScannerHolder |
RSRpcServices.getRegionScannerHolder(long scannerId)
Returns The associated RegionScannerHolder for
scannerId or null. |
Modifier and Type | Method and Description |
---|---|
private Pair<String,RSRpcServices.RegionScannerHolder> |
RSRpcServices.newRegionScanner(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request,
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse.Builder builder) |
Modifier and Type | Method and Description |
---|---|
private void |
RSRpcServices.checkScanNextCallSeq(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request,
RSRpcServices.RegionScannerHolder rsh) |
private void |
RSRpcServices.runShippedCallback(RSRpcServices.RegionScannerHolder rsh) |
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,
RpcCall rpcCall) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.