Package org.apache.hadoop.hbase

Class TestPerformanceEvaluation.PESampleTestImpl

java.lang.Object

org.apache.hadoop.hbase.TestPerformanceEvaluation.PESampleTestImpl

Enclosing class:

TestPerformanceEvaluation

class TestPerformanceEvaluation.PESampleTestImpl
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.apache.hadoop.conf.Configuration	conf
protected org.apache.hadoop.hbase.client.Connection	connection
protected com.codahale.metrics.Histogram	latencyHistogram
protected final org.apache.hadoop.hbase.PerformanceEvaluation.TestOptions	opts
protected final org.apache.hadoop.hbase.PerformanceEvaluation.Status	status

Constructor Summary

Constructors

Constructor	Description
PESampleTestImpl(org.apache.hadoop.hbase.client.Connection con, org.apache.hadoop.hbase.PerformanceEvaluation.TestOptions options, org.apache.hadoop.hbase.PerformanceEvaluation.Status status)

Method Summary

Modifier and Type	Method	Description
(package private) String	generateStatus(long arg0, long arg1, long arg2)
(package private) long	getLastRow()
com.codahale.metrics.Histogram	getLatencyHistogram()
protected long	getReportingPeriod()
String	getShortLatencyReport()
String	getShortValueSizeReport()
(package private) long	getStartRow()
(package private) int	getValueLength()
(package private) boolean	isRandomValueSize()
(package private) void	onStartup()
(package private) void	onTakedown()
(package private) long	test()
(package private) boolean	testRow(long i, long startTime)
(package private) void	testSetup()
(package private) void	testTakedown()
(package private) void	testTimed()
(package private) void	updateScanMetrics(org.apache.hadoop.hbase.client.metrics.ScanMetrics arg0)
(package private) void	updateValueSize(int arg0)
(package private) void	updateValueSize(org.apache.hadoop.hbase.client.Result arg0)
(package private) void	updateValueSize(org.apache.hadoop.hbase.client.Result[] arg0)
(package private) void	updateValueSize(org.apache.hadoop.hbase.client.Result[] arg0, long arg1)
(package private) void	updateValueSize(org.apache.hadoop.hbase.client.Result arg0, long arg1)

Methods inherited from class java.lang.Object

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

Field Details

connection

protected org.apache.hadoop.hbase.client.Connection connection

conf

protected final org.apache.hadoop.conf.Configuration conf

opts

protected final org.apache.hadoop.hbase.PerformanceEvaluation.TestOptions opts

status

protected final org.apache.hadoop.hbase.PerformanceEvaluation.Status status

latencyHistogram

protected com.codahale.metrics.Histogram latencyHistogram

Constructor Details

PESampleTestImpl

PESampleTestImpl(org.apache.hadoop.hbase.client.Connection con,
 org.apache.hadoop.hbase.PerformanceEvaluation.TestOptions options,
 org.apache.hadoop.hbase.PerformanceEvaluation.Status status)

Method Details

onStartup

void onStartup()
        throws IOException

Throws:

IOException

onTakedown

void onTakedown()
         throws IOException

Throws:

IOException

testRow

boolean testRow(long i,
 long startTime)
         throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getValueLength

int getValueLength()

updateValueSize

void updateValueSize(org.apache.hadoop.hbase.client.Result[] arg0)
              throws IOException

Throws:

IOException

updateValueSize

void updateValueSize(org.apache.hadoop.hbase.client.Result[] arg0,
 long arg1)
              throws IOException

Throws:

IOException

updateValueSize

void updateValueSize(org.apache.hadoop.hbase.client.Result arg0)
              throws IOException

Throws:

IOException

updateValueSize

void updateValueSize(org.apache.hadoop.hbase.client.Result arg0,
 long arg1)
              throws IOException

Throws:

IOException

updateValueSize

void updateValueSize(int arg0)

updateScanMetrics

void updateScanMetrics(org.apache.hadoop.hbase.client.metrics.ScanMetrics arg0)

generateStatus

String generateStatus(long arg0,
 long arg1,
 long arg2)

isRandomValueSize

boolean isRandomValueSize()

getReportingPeriod

protected long getReportingPeriod()

getLatencyHistogram

public com.codahale.metrics.Histogram getLatencyHistogram()

testSetup

void testSetup()
        throws IOException

Throws:

IOException

testTakedown

void testTakedown()
           throws IOException

Throws:

IOException

test

long test()
   throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getStartRow

long getStartRow()

getLastRow

long getLastRow()

testTimed

void testTimed()
        throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getShortLatencyReport

public String getShortLatencyReport()

getShortValueSizeReport

public String getShortValueSizeReport()