org.apache.hadoop.hbase.test

Class IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader.TimeBoundedMultiThreadedReaderThread

java.lang.Object

java.lang.Thread

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

org.apache.hadoop.hbase.test.IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader.TimeBoundedMultiThreadedReaderThread

All Implemented Interfaces:

Runnable

Enclosing class:

IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader

public class IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader.TimeBoundedMultiThreadedReaderThread
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
TimeBoundedMultiThreadedReaderThread(int readerId)

Method Summary

Modifier and Type	Method and Description
protected Get	createGet(long keyToRead)
protected long	getNextKeyToRead()
protected void	verifyResultsAndUpdateMetrics(boolean verify, Get[] gets, long elapsedNano, Result[] results, Table table, boolean isNullExpected)

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

closeTable, createTable, queryKey, queryKey, run, 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

TimeBoundedMultiThreadedReaderThread

public TimeBoundedMultiThreadedReaderThread(int readerId)
                                     throws IOException

Throws:

IOException

Method Detail

createGet

protected Get createGet(long keyToRead)
                 throws IOException

Overrides:

createGet in class MultiThreadedReader.HBaseReaderThread

Throws:

IOException

getNextKeyToRead

protected long getNextKeyToRead()

Overrides:

getNextKeyToRead in class MultiThreadedReader.HBaseReaderThread

verifyResultsAndUpdateMetrics

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

Overrides:

verifyResultsAndUpdateMetrics in class MultiThreadedReader.HBaseReaderThread

Throws:

IOException