Package org.apache.hadoop.hbase
Class PerformanceEvaluation.TestBase
java.lang.Object
org.apache.hadoop.hbase.PerformanceEvaluation.TestBase
- Direct Known Subclasses:
PerformanceEvaluation.AsyncTest
,PerformanceEvaluation.Test
- Enclosing class:
- PerformanceEvaluation
-
Field Summary
Modifier and TypeFieldDescriptionprivate com.codahale.metrics.Histogram
private com.codahale.metrics.Histogram
protected final org.apache.hadoop.conf.Configuration
private final int
protected com.codahale.metrics.Histogram
private com.codahale.metrics.Histogram
private long
private long
protected final PerformanceEvaluation.TestOptions
protected final Random
private static final Random
private com.codahale.metrics.Histogram
private com.codahale.metrics.Histogram
private com.codahale.metrics.Histogram
private com.codahale.metrics.Histogram
protected final PerformanceEvaluation.Status
private String
private com.codahale.metrics.Histogram
private RandomDistribution.Zipf
-
Constructor Summary
ConstructorDescriptionTestBase
(org.apache.hadoop.conf.Configuration conf, PerformanceEvaluation.TestOptions options, PerformanceEvaluation.Status status) Note that all subclasses of this class must provide a public constructor that has the exact same list of arguments. -
Method Summary
Modifier and TypeMethodDescription(package private) String
generateStatus
(int sr, int i, int lr) (package private) int
com.codahale.metrics.Histogram
Populated by testTakedown.protected int
Returns Subset of the histograms' calculation.Returns Subset of the histograms' calculation.(package private) int
(package private) int
(package private) boolean
private static long
(package private) abstract void
(package private) abstract void
(package private) long
test()
(package private) abstract boolean
testRow
(int i, long startTime) Test for individual row.(package private) void
(package private) void
(package private) void
Provides an extension point for tests that don't want a per row invocation.(package private) void
updateScanMetrics
(org.apache.hadoop.hbase.client.metrics.ScanMetrics metrics) (package private) void
updateValueSize
(int valueSize) (package private) void
updateValueSize
(org.apache.hadoop.hbase.client.Result r) (package private) void
updateValueSize
(org.apache.hadoop.hbase.client.Result[] rs) (package private) void
updateValueSize
(org.apache.hadoop.hbase.client.Result[] rs, long latency) (package private) void
updateValueSize
(org.apache.hadoop.hbase.client.Result r, long latency)
-
Field Details
-
randomSeed
-
everyN
-
rand
-
conf
-
opts
-
status
-
testName
-
latencyHistogram
-
replicaLatencyHistogram
-
valueSizeHistogram
-
rpcCallsHistogram
-
remoteRpcCallsHistogram
-
millisBetweenNextHistogram
-
regionsScannedHistogram
-
bytesInResultsHistogram
-
bytesInRemoteResultsHistogram
-
zipf
-
numOfReplyOverLatencyThreshold
-
numOfReplyFromReplica
-
-
Constructor Details
-
TestBase
TestBase(org.apache.hadoop.conf.Configuration conf, PerformanceEvaluation.TestOptions options, PerformanceEvaluation.Status status) Note that all subclasses of this class must provide a public constructor that has the exact same list of arguments.
-
-
Method Details
-
nextRandomSeed
-
getValueLength
-
updateValueSize
- Throws:
IOException
-
updateValueSize
- Throws:
IOException
-
updateValueSize
- Throws:
IOException
-
updateValueSize
- Throws:
IOException
-
updateValueSize
-
updateScanMetrics
-
generateStatus
-
isRandomValueSize
boolean isRandomValueSize() -
getReportingPeriod
-
getLatencyHistogram
Populated by testTakedown. Only implemented by RandomReadTest at the moment. -
testSetup
- Throws:
IOException
-
onStartup
- Throws:
IOException
-
testTakedown
- Throws:
IOException
-
onTakedown
- Throws:
IOException
-
test
- Throws:
IOException
InterruptedException
-
getStartRow
int getStartRow() -
getLastRow
int getLastRow() -
testTimed
Provides an extension point for tests that don't want a per row invocation.- Throws:
IOException
InterruptedException
-
getShortLatencyReport
Returns Subset of the histograms' calculation. -
getShortValueSizeReport
Returns Subset of the histograms' calculation. -
testRow
Test for individual row.- Parameters:
i
- Row index.- Returns:
- true if the row was sent to server and need to record metrics. False if not, multiGet and multiPut e.g., the rows are sent to server only if enough gets/puts are gathered.
- Throws:
IOException
InterruptedException
-