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 Random	rand
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(int arg0, int arg1, int arg2)
(package private) int	getLastRow()
com.codahale.metrics.Histogram	getLatencyHistogram()
protected int	getReportingPeriod()
String	getShortLatencyReport()
String	getShortValueSizeReport()
(package private) int	getStartRow()
(package private) int	getValueLength(Random arg0)
(package private) boolean	isRandomValueSize()
(package private) void	onStartup()
(package private) void	onTakedown()
(package private) long	test()
(package private) boolean	testRow(int 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

rand

protected final Random rand

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(int i,
 long startTime)
         throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getValueLength

int getValueLength(Random arg0)

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(int arg0,
 int arg1,
 int arg2)

isRandomValueSize

boolean isRandomValueSize()

getReportingPeriod

protected int 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

int getStartRow()

getLastRow

int getLastRow()

testTimed

void testTimed()
        throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getShortLatencyReport

public String getShortLatencyReport()

getShortValueSizeReport

public String getShortValueSizeReport()