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:

Runnable

Enclosing class:

MultiThreadedReaderWithACL

public class MultiThreadedReaderWithACL.HBaseReaderThreadWithACL
extends MultiThreadedReader.HBaseReaderThread

Nested Class Summary

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

Thread.State, 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 org.apache.hadoop.hbase.client.Table	createTable()
void	queryKey(org.apache.hadoop.hbase.client.Get get, boolean verify, long keyToRead)
private void	recordFailure(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 IOException

Throws:

IOException

Method Detail

createTable

protected org.apache.hadoop.hbase.client.Table createTable()
                                                    throws IOException

Overrides:

createTable in class MultiThreadedReader.HBaseReaderThread

Throws:

IOException

closeTable

protected void closeTable()

Overrides:

closeTable in class MultiThreadedReader.HBaseReaderThread

queryKey

public void queryKey(org.apache.hadoop.hbase.client.Get get,
                     boolean verify,
                     long keyToRead)
              throws IOException

Overrides:

queryKey in class MultiThreadedReader.HBaseReaderThread

Throws:

IOException

recordFailure

private void recordFailure(long keyToRead)