public static class IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader
extends MultiThreadedReader
Modifier and Type | Class and Description |
---|---|
class |
IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader.TimeBoundedMultiThreadedReaderThread |
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 and Description |
---|
TimeBoundedMultiThreadedReader(LoadTestDataGenerator dataGen,
Configuration conf,
TableName tableName,
double verifyPercent) |
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() |
protected long timeoutNano
protected java.util.concurrent.atomic.AtomicLong timedOutReads
protected long runTime
protected java.lang.Thread timeoutThread
protected java.util.concurrent.atomic.AtomicLong staleReads
public TimeBoundedMultiThreadedReader(LoadTestDataGenerator dataGen, Configuration conf, TableName tableName, double verifyPercent) throws java.io.IOException
java.io.IOException
public void waitForFinish()
protected java.lang.String progressInfo()
public void start(long startKey, long endKey, int numThreads) throws java.io.IOException
java.io.IOException
protected HBaseReaderThread createReaderThread(int readerId) throws java.io.IOException
java.io.IOException