public class MultiThreadedReader.HBaseReaderThread
extends java.lang.Thread
Modifier and Type | Field and Description |
---|---|
protected int |
readerId |
protected long |
startTimeMs
Time when the thread started
|
protected Table |
table |
Constructor and Description |
---|
HBaseReaderThread(int readerId) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeTable() |
protected Get |
createGet(long keyToRead) |
protected HTableInterface |
createTable() |
protected long |
getNextKeyToRead() |
void |
queryKey(Get[] gets,
boolean verify,
long[] keysToRead) |
void |
queryKey(Get get,
boolean verify,
long keyToRead) |
void |
run() |
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) |
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
protected final int readerId
protected final Table table
protected long startTimeMs
public HBaseReaderThread(int readerId) throws java.io.IOException
readerId
- only the keys with this remainder from division by
MultiThreadedAction.numThreads
will be read by this threadjava.io.IOException
protected HTableInterface createTable() throws java.io.IOException
java.io.IOException
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
protected void closeTable()
protected long getNextKeyToRead()
protected Get createGet(long keyToRead) throws java.io.IOException
java.io.IOException
public void queryKey(Get[] gets, boolean verify, long[] keysToRead) throws java.io.IOException
java.io.IOException
public void queryKey(Get get, boolean verify, long keyToRead) throws java.io.IOException
java.io.IOException
protected void verifyResultsAndUpdateMetrics(boolean verify, Get[] gets, long elapsedNano, Result[] results, Table table, boolean isNullExpected) throws java.io.IOException
java.io.IOException
protected void verifyResultsAndUpdateMetrics(boolean verify, Get get, long elapsedNano, Result result, Table table, boolean isNullExpected) throws java.io.IOException
java.io.IOException