public class MultiThreadedReaderWithACL.HBaseReaderThreadWithACL extends MultiThreadedReader.HBaseReaderThread
readerId, startTimeMs, table
Constructor and Description |
---|
HBaseReaderThreadWithACL(int readerId) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeTable() |
protected HTableInterface |
createTable() |
void |
queryKey(Get get,
boolean verify,
long keyToRead) |
createGet, getNextKeyToRead, queryKey, run, verifyResultsAndUpdateMetrics, verifyResultsAndUpdateMetrics
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
public HBaseReaderThreadWithACL(int readerId) throws java.io.IOException
java.io.IOException
protected HTableInterface createTable() throws java.io.IOException
createTable
in class MultiThreadedReader.HBaseReaderThread
java.io.IOException
protected void closeTable()
closeTable
in class MultiThreadedReader.HBaseReaderThread
public void queryKey(Get get, boolean verify, long keyToRead) throws java.io.IOException
queryKey
in class MultiThreadedReader.HBaseReaderThread
java.io.IOException