org.apache.hadoop.hbase.test

Class IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader

java.lang.Object

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

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected HBaseReaderThread	createReaderThread(int readerId)
protected String	progressInfo()
void	start(long startKey, long endKey, int numThreads)
void	waitForFinish()

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()

progressInfo

protected String progressInfo()

start

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

Throws:

IOException

createReaderThread

protected HBaseReaderThread createReaderThread(int readerId)
                                        throws IOException

Throws:

IOException