static final class RSRpcServices.RegionScannerHolder extends Object
Modifier and Type | Field and Description |
---|---|
private String |
clientIPAndPort |
private RpcCallback |
closeCallBack |
private boolean |
fullRegionScan |
private long |
maxBlockBytesScanned |
private boolean |
needCursor |
private AtomicLong |
nextCallSeq |
private long |
prevBlockBytesScanned |
private long |
prevBlockBytesScannedDifference |
private HRegion |
r |
private byte[] |
rowOfLastPartialResult |
private RegionScanner |
s |
private RpcCallback |
shippedCallback |
private String |
userName |
Constructor and Description |
---|
RegionScannerHolder(RegionScanner s,
HRegion r,
RpcCallback closeCallBack,
RpcCallback shippedCallback,
boolean needCursor,
boolean fullRegionScan,
String clientIPAndPort,
String userName) |
Modifier and Type | Method and Description |
---|---|
(package private) long |
getMaxBlockBytesScanned() |
(package private) long |
getNextCallSeq() |
(package private) long |
getPrevBlockBytesScannedDifference() |
(package private) boolean |
incNextCallSeq(long currentSeq) |
String |
toString() |
(package private) void |
updateBlockBytesScanned(long blockBytesScanned) |
private final AtomicLong nextCallSeq
private final RegionScanner s
private final RpcCallback closeCallBack
private final RpcCallback shippedCallback
private byte[] rowOfLastPartialResult
private boolean needCursor
private boolean fullRegionScan
private final String clientIPAndPort
private volatile long maxBlockBytesScanned
private volatile long prevBlockBytesScanned
private volatile long prevBlockBytesScannedDifference
RegionScannerHolder(RegionScanner s, HRegion r, RpcCallback closeCallBack, RpcCallback shippedCallback, boolean needCursor, boolean fullRegionScan, String clientIPAndPort, String userName)
long getNextCallSeq()
boolean incNextCallSeq(long currentSeq)
long getMaxBlockBytesScanned()
long getPrevBlockBytesScannedDifference()
void updateBlockBytesScanned(long blockBytesScanned)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.