Package org.apache.hadoop.hbase.regionserver

Class RSRpcServices.RegionScannerHolder

java.lang.Object

org.apache.hadoop.hbase.regionserver.RSRpcServices.RegionScannerHolder

Enclosing class:

RSRpcServices

static final class RSRpcServices.RegionScannerHolder
extends Object

Holder class which holds the RegionScanner, nextCallSeq and RpcCallbacks together.

Field Summary

Fields

Modifier and Type	Field	Description
private final String	clientIPAndPort
private final RpcCallback	closeCallBack
private boolean	fullRegionScan
private long	maxBlockBytesScanned
private boolean	needCursor
private final AtomicLong	nextCallSeq
private long	prevBlockBytesScanned
private long	prevBlockBytesScannedDifference
private final HRegion	r
private byte[]	rowOfLastPartialResult
private final RegionScanner	s
private final RpcCallback	shippedCallback
private final String	userName

Constructor Summary

Constructors

Constructor	Description
RegionScannerHolder(RegionScanner s, HRegion r, RpcCallback closeCallBack, RpcCallback shippedCallback, boolean needCursor, boolean fullRegionScan, String clientIPAndPort, String userName)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

nextCallSeq

private final AtomicLong nextCallSeq

s

private final RegionScanner s

r

private final HRegion r

closeCallBack

private final RpcCallback closeCallBack

shippedCallback

private final RpcCallback shippedCallback

rowOfLastPartialResult

private byte[] rowOfLastPartialResult

needCursor

private boolean needCursor

fullRegionScan

private boolean fullRegionScan

clientIPAndPort

private final String clientIPAndPort

userName

private final String userName

maxBlockBytesScanned

private volatile long maxBlockBytesScanned

prevBlockBytesScanned

private volatile long prevBlockBytesScanned

prevBlockBytesScannedDifference

private volatile long prevBlockBytesScannedDifference

Constructor Details

RegionScannerHolder

RegionScannerHolder(RegionScanner s,
 HRegion r,
 RpcCallback closeCallBack,
 RpcCallback shippedCallback,
 boolean needCursor,
 boolean fullRegionScan,
 String clientIPAndPort,
 String userName)

Method Details

getNextCallSeq

long getNextCallSeq()

incNextCallSeq

boolean incNextCallSeq(long currentSeq)

getMaxBlockBytesScanned

long getMaxBlockBytesScanned()

getPrevBlockBytesScannedDifference

long getPrevBlockBytesScannedDifference()

updateBlockBytesScanned

void updateBlockBytesScanned(long blockBytesScanned)

toString

public String toString()

Overrides:

toString in class Object