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 java.util.concurrent.atomic.AtomicLong	staleReads
protected java.util.concurrent.atomic.AtomicLong	timedOutReads
protected long	timeoutNano
protected java.lang.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 java.lang.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 java.util.concurrent.atomic.AtomicLong timedOutReads

runTime

protected long runTime

timeoutThread

protected java.lang.Thread timeoutThread

staleReads

protected java.util.concurrent.atomic.AtomicLong staleReads

Constructor Detail

TimeBoundedMultiThreadedReader

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

Throws:

java.io.IOException

Method Detail

waitForFinish

public void waitForFinish()

progressInfo

protected java.lang.String progressInfo()

start

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

Throws:

java.io.IOException

createReaderThread

protected HBaseReaderThread createReaderThread(int readerId)
                                        throws java.io.IOException

Throws:

java.io.IOException