org.apache.hadoop.hbase.util

Class MultiThreadedReaderWithACL.HBaseReaderThreadWithACL

java.lang.Object

java.lang.Thread

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

org.apache.hadoop.hbase.util.MultiThreadedReaderWithACL.HBaseReaderThreadWithACL

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

MultiThreadedReaderWithACL

public class MultiThreadedReaderWithACL.HBaseReaderThreadWithACL
extends MultiThreadedReader.HBaseReaderThread

Nested Class Summary

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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class org.apache.hadoop.hbase.util.MultiThreadedReader.HBaseReaderThread

readerId, startTimeMs, table

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
HBaseReaderThreadWithACL(int readerId)

Method Summary

Modifier and Type	Method and Description
protected void	closeTable()
protected HTableInterface	createTable()
void	queryKey(Get get, boolean verify, long keyToRead)

Methods inherited from class org.apache.hadoop.hbase.util.MultiThreadedReader.HBaseReaderThread

createGet, getNextKeyToRead, queryKey, run, verifyResultsAndUpdateMetrics, verifyResultsAndUpdateMetrics

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseReaderThreadWithACL

public HBaseReaderThreadWithACL(int readerId)
                         throws java.io.IOException

Throws:

java.io.IOException

Method Detail

createTable

protected HTableInterface createTable()
                               throws java.io.IOException

Overrides:

createTable in class MultiThreadedReader.HBaseReaderThread

Throws:

java.io.IOException

closeTable

protected void closeTable()

Overrides:

closeTable in class MultiThreadedReader.HBaseReaderThread

queryKey

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

Overrides:

queryKey in class MultiThreadedReader.HBaseReaderThread

Throws:

java.io.IOException