org.apache.hadoop.hbase.test

Class IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader.TimeBoundedMultiThreadedReaderThread

java.lang.Object

MultiThreadedReader.HBaseReaderThread

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

Enclosing class:

IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader

public class IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader.TimeBoundedMultiThreadedReaderThread
extends MultiThreadedReader.HBaseReaderThread

Constructor Summary

Constructors

Constructor and Description
TimeBoundedMultiThreadedReaderThread(int readerId)

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeBoundedMultiThreadedReaderThread

public TimeBoundedMultiThreadedReaderThread(int readerId)
                                     throws java.io.IOException

Throws:

java.io.IOException

Method Detail

createGet

protected Get createGet(long keyToRead)
                 throws java.io.IOException

Throws:

java.io.IOException

getNextKeyToRead

protected long getNextKeyToRead()

verifyResultsAndUpdateMetrics

protected void verifyResultsAndUpdateMetrics(boolean verify,
                                             Get[] gets,
                                             long elapsedNano,
                                             Result[] results,
                                             Table table,
                                             boolean isNullExpected)
                                      throws java.io.IOException

Throws:

java.io.IOException