public class IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader.TimeBoundedMultiThreadedReaderThread
extends MultiThreadedReader.HBaseReaderThread
Constructor and Description |
---|
TimeBoundedMultiThreadedReaderThread(int readerId) |
Modifier and Type | Method and Description |
---|---|
protected Get |
createGet(long keyToRead) |
protected long |
getNextKeyToRead() |
protected void |
verifyResultsAndUpdateMetrics(boolean verify,
Get[] gets,
long elapsedNano,
Result[] results,
Table table,
boolean isNullExpected) |
public TimeBoundedMultiThreadedReaderThread(int readerId) throws java.io.IOException
java.io.IOException
protected Get createGet(long keyToRead) throws java.io.IOException
java.io.IOException
protected long getNextKeyToRead()