Package 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 org.apache.hadoop.hbase.util.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	Description
TimeBoundedMultiThreadedReaderThread(int readerId)

Method Summary

Modifier and Type	Method	Description
protected org.apache.hadoop.hbase.client.Get	createGet(long keyToRead)
protected long	getNextKeyToRead()
protected void	verifyResultsAndUpdateMetrics(boolean verify, org.apache.hadoop.hbase.client.Get[] gets, long elapsedNano, org.apache.hadoop.hbase.client.Result[] results, org.apache.hadoop.hbase.client.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, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Details

TimeBoundedMultiThreadedReaderThread

public TimeBoundedMultiThreadedReaderThread(int readerId)
                                     throws IOException

Throws:

IOException

Method Details

createGet

protected org.apache.hadoop.hbase.client.Get createGet(long keyToRead)
                                                throws IOException

Overrides:

createGet in class org.apache.hadoop.hbase.util.MultiThreadedReader.HBaseReaderThread

Throws:

IOException

getNextKeyToRead

protected long getNextKeyToRead()

Overrides:

getNextKeyToRead in class org.apache.hadoop.hbase.util.MultiThreadedReader.HBaseReaderThread

verifyResultsAndUpdateMetrics

protected void verifyResultsAndUpdateMetrics(boolean verify,
 org.apache.hadoop.hbase.client.Get[] gets,
 long elapsedNano,
 org.apache.hadoop.hbase.client.Result[] results,
 org.apache.hadoop.hbase.client.Table table,
 boolean isNullExpected)
                                      throws IOException

Overrides:

verifyResultsAndUpdateMetrics in class org.apache.hadoop.hbase.util.MultiThreadedReader.HBaseReaderThread

Throws:

IOException