org.apache.hadoop.hbase.test

Class IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader

java.lang.Object

org.apache.hadoop.hbase.util.MultiThreadedAction

org.apache.hadoop.hbase.util.MultiThreadedReader

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

Enclosing class:

IntegrationTestTimeBoundedRequestsWithRegionReplicas

public static class IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader
extends MultiThreadedReader

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader.TimeBoundedMultiThreadedReaderThread

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.util.MultiThreadedReader

MultiThreadedReader.HBaseReaderThread

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.util.MultiThreadedAction

MultiThreadedAction.DefaultDataGenerator

Field Summary

Fields

Modifier and Type	Field and Description
protected long	runTime
protected AtomicLong	staleReads
protected AtomicLong	timedOutReads
protected long	timeoutNano
protected Thread	timeoutThread

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

aborted, DEFAULT_BATCH_SIZE, DEFAULT_KEY_WINDOW, DEFAULT_MAX_ERRORS, nullResult, numKeysVerified, numReadErrors, numReadFailures, readers, writer

Fields inherited from class org.apache.hadoop.hbase.util.MultiThreadedAction

conf, connection, dataGenerator, endKey, numCols, numKeys, numThreads, numThreadsWorking, REPORTING_INTERVAL_MS, startKey, tableName, totalOpTimeMs, verbose

Constructor Summary

Constructors

Constructor and Description
TimeBoundedMultiThreadedReader(LoadTestDataGenerator dataGen, Configuration conf, TableName tableName, double verifyPercent)

Method Summary

Modifier and Type	Method and Description
protected MultiThreadedReader.HBaseReaderThread	createReaderThread(int readerId)
protected String	progressInfo() Returns a task-specific progress string
void	start(long startKey, long endKey, int numThreads)
void	waitForFinish()

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

addReaderThreads, getNullResultsCount, getNumKeysVerified, getNumReadErrors, getNumReadFailures, getNumUniqueKeysVerified, linkToWriter, setKeyWindow, setMaxErrors, setMultiGetBatchSize, setRegionReplicaId

Methods inherited from class org.apache.hadoop.hbase.util.MultiThreadedAction

appendToStatus, appendToStatus, close, getEndKey, isDone, startThreads, verifyResultAgainstDataGenerator, verifyResultAgainstDataGenerator

Methods inherited from class java.lang.Object

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

Field Detail

timeoutNano

protected long timeoutNano

timedOutReads

protected AtomicLong timedOutReads

runTime

protected long runTime

timeoutThread

protected Thread timeoutThread

staleReads

protected AtomicLong staleReads

Constructor Detail

TimeBoundedMultiThreadedReader

public TimeBoundedMultiThreadedReader(LoadTestDataGenerator dataGen,
                                      Configuration conf,
                                      TableName tableName,
                                      double verifyPercent)
                               throws IOException

Throws:

IOException

Method Detail

waitForFinish

public void waitForFinish()

Overrides:

waitForFinish in class MultiThreadedAction

progressInfo

protected String progressInfo()

Description copied from class: MultiThreadedAction

Returns a task-specific progress string

Overrides:

progressInfo in class MultiThreadedReader

start

public void start(long startKey,
                  long endKey,
                  int numThreads)
           throws IOException

Overrides:

start in class MultiThreadedReader

Throws:

IOException

createReaderThread

protected MultiThreadedReader.HBaseReaderThread createReaderThread(int readerId)
                                                            throws IOException

Overrides:

createReaderThread in class MultiThreadedReader

Throws:

IOException