Package org.apache.hadoop.hbase.util

Class MultiThreadedReader.HBaseReaderThread

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.util.MultiThreadedReader.HBaseReaderThread

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

MultiThreadedReaderWithACL.HBaseReaderThreadWithACL

Enclosing class:

MultiThreadedReader

public class MultiThreadedReader.HBaseReaderThread
extends Thread

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private long	curKey	The "current" key being read.
private boolean	printExceptionTrace
protected final int	readerId
private boolean	readingRandomKey	If we are ahead of the writer and reading a random key.
protected long	startTimeMs	Time when the thread started
protected final Table	table

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
HBaseReaderThread(int readerId)

Method Summary

Modifier and Type	Method	Description
protected void	closeTable()
protected Get	createGet(long keyToRead)
protected Table	createTable()
protected long	getNextKeyToRead()
private long	maxKeyWeCanRead()	Should only be used for the concurrent writer/reader workload.
void	queryKey(Get[] gets, boolean verify, long[] keysToRead)
void	queryKey(Get get, boolean verify, long keyToRead)
private Get[]	readKey(long[] keysToRead)
void	run()
private void	runReader()
protected void	verifyResultsAndUpdateMetrics(boolean verify, Get[] gets, long elapsedNano, Result[] results, Table table, boolean isNullExpected)
protected void	verifyResultsAndUpdateMetrics(boolean verify, Get get, long elapsedNano, Result result, Table table, boolean isNullExpected)
private void	verifyResultsAndUpdateMetricsOnAPerGetBasis(boolean verify, Get get, Result result, Table table, boolean isNullExpected)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Details

readerId

protected final int readerId

table

protected final Table table

curKey

private long curKey

The "current" key being read. Increases from startKey to endKey.

startTimeMs

protected long startTimeMs

Time when the thread started

readingRandomKey

private boolean readingRandomKey

If we are ahead of the writer and reading a random key.

printExceptionTrace

private boolean printExceptionTrace

Constructor Details

HBaseReaderThread

public HBaseReaderThread(int readerId)
                  throws IOException

Parameters:

readerId - only the keys with this remainder from division by MultiThreadedAction.numThreads will be read by this thread

Throws:

IOException

Method Details

createTable

protected Table createTable()
                     throws IOException

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

closeTable

protected void closeTable()

runReader

private void runReader()

maxKeyWeCanRead

private long maxKeyWeCanRead()

Should only be used for the concurrent writer/reader workload. The maximum key we are allowed to read, subject to the "key window" constraint.

getNextKeyToRead

protected long getNextKeyToRead()

readKey

private Get[] readKey(long[] keysToRead)

createGet

protected Get createGet(long keyToRead)
                 throws IOException

Throws:

IOException

queryKey

public void queryKey(Get[] gets,
 boolean verify,
 long[] keysToRead)
              throws IOException

Throws:

IOException

queryKey

public void queryKey(Get get,
 boolean verify,
 long keyToRead)
              throws IOException

Throws:

IOException

verifyResultsAndUpdateMetrics

protected void verifyResultsAndUpdateMetrics(boolean verify,
 Get[] gets,
 long elapsedNano,
 Result[] results,
 Table table,
 boolean isNullExpected)
                                      throws IOException

Throws:

IOException

verifyResultsAndUpdateMetrics

protected void verifyResultsAndUpdateMetrics(boolean verify,
 Get get,
 long elapsedNano,
 Result result,
 Table table,
 boolean isNullExpected)
                                      throws IOException

Throws:

IOException

verifyResultsAndUpdateMetricsOnAPerGetBasis

private void verifyResultsAndUpdateMetricsOnAPerGetBasis(boolean verify,
 Get get,
 Result result,
 Table table,
 boolean isNullExpected)
                                                  throws IOException

Throws:

IOException