public class PerformanceEvaluation
extends Configured
PerformanceEvaluation --help
to obtain usage.
This class sets up and runs the evaluation programs described in Section 7, Performance Evaluation, of the Bigtable paper, pages 8-10.
By default, runs as a mapreduce job where each mapper runs a single test
client. Can also run as a non-mapreduce, multithreaded application by
specifying --nomapred
. Each client does about 1GB of data, unless
specified otherwise.
Modifier and Type | Class and Description |
---|---|
protected static class |
PerformanceEvaluation.Counter
Enum for map metrics.
|
static class |
PerformanceEvaluation.EvaluationMapTask
MapReduce job that runs a performance evaluation client in each map task.
|
protected static class |
PerformanceEvaluation.RunResult |
Modifier and Type | Field and Description |
---|---|
static byte[] |
COLUMN_ZERO |
static int |
DEFAULT_VALUE_LENGTH |
static java.lang.String |
FAMILY_NAME_BASE |
static byte[] |
FAMILY_ZERO |
static int |
ROW_LENGTH |
static java.lang.String |
TABLE_NAME |
Constructor and Description |
---|
PerformanceEvaluation(Configuration conf)
Constructor
|
Modifier and Type | Method and Description |
---|---|
protected static void |
addCommandDescriptor(java.lang.Class<? extends org.apache.hadoop.hbase.PerformanceEvaluation.TestBase> cmdClass,
java.lang.String name,
java.lang.String description) |
static byte[] |
format(int number) |
static byte[] |
generateData(java.util.Random r,
int length) |
protected static byte[][] |
getSplits(org.apache.hadoop.hbase.PerformanceEvaluation.TestOptions opts)
generates splits based on total number of rows and specified split regions
|
protected static HTableDescriptor |
getTableDescriptor(org.apache.hadoop.hbase.PerformanceEvaluation.TestOptions opts)
Create an HTableDescriptor from provided TestOptions.
|
static void |
main(java.lang.String[] args) |
protected void |
printUsage() |
protected static void |
printUsage(java.lang.String message) |
protected static void |
printUsage(java.lang.String className,
java.lang.String message) |
protected static void |
printUsageAndExit(java.lang.String message,
int exitCode) |
int |
run(java.lang.String[] args) |
public static final java.lang.String TABLE_NAME
public static final java.lang.String FAMILY_NAME_BASE
public static final byte[] FAMILY_ZERO
public static final byte[] COLUMN_ZERO
public static final int DEFAULT_VALUE_LENGTH
public static final int ROW_LENGTH
public PerformanceEvaluation(Configuration conf)
conf
- Configuration objectprotected static void addCommandDescriptor(java.lang.Class<? extends org.apache.hadoop.hbase.PerformanceEvaluation.TestBase> cmdClass, java.lang.String name, java.lang.String description)
protected static HTableDescriptor getTableDescriptor(org.apache.hadoop.hbase.PerformanceEvaluation.TestOptions opts)
protected static byte[][] getSplits(org.apache.hadoop.hbase.PerformanceEvaluation.TestOptions opts)
public static byte[] format(int number)
public static byte[] generateData(java.util.Random r, int length)
protected void printUsage()
protected static void printUsage(java.lang.String message)
protected static void printUsageAndExit(java.lang.String message, int exitCode)
protected static void printUsage(java.lang.String className, java.lang.String message)
public int run(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception