public class PerformanceEvaluation
extends Configured
java 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.
If number of clients > 1, we start up a MapReduce job. Each map task runs an individual client. Each client does about 1GB of data.
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.
|
static class |
PerformanceEvaluation.PeInputFormat
InputFormat of Performance Evaluation MapReduce job.
|
static class |
PerformanceEvaluation.PeInputSplit
This class works as the InputSplit of Performance Evaluation
MapReduce InputFormat, and the Record Value of RecordReader.
|
Modifier and Type | Field and Description |
---|---|
protected static Cluster |
cluster |
protected Map<String,org.apache.hadoop.hbase.rest.PerformanceEvaluation.CmdDescriptor> |
commands |
static byte[] |
FAMILY_NAME |
static Pattern |
LINE_PATTERN
Regex to parse lines in input file passed to mapreduce task.
|
protected static Log |
LOG |
static byte[] |
QUALIFIER_NAME |
protected HTableDescriptor |
TABLE_DESCRIPTOR |
static TableName |
TABLE_NAME |
Constructor and Description |
---|
PerformanceEvaluation(Configuration c)
Constructor
|
Modifier and Type | Method and Description |
---|---|
protected void |
addCommandDescriptor(Class<? extends org.apache.hadoop.hbase.rest.PerformanceEvaluation.Test> cmdClass,
String name,
String description) |
static byte[] |
format(int number) |
static byte[] |
generateData(Random r,
int length) |
static byte[] |
generateValue(Random r) |
protected byte[][] |
getSplits()
Generates splits based on total number of rows and specified split regions
|
protected HTableDescriptor |
getTableDescriptor() |
static void |
main(String[] args) |
protected void |
printUsage() |
protected void |
printUsage(String message) |
int |
run(String[] args) |
protected static final Log LOG
public static final TableName TABLE_NAME
public static final byte[] FAMILY_NAME
public static final byte[] QUALIFIER_NAME
protected HTableDescriptor TABLE_DESCRIPTOR
protected Map<String,org.apache.hadoop.hbase.rest.PerformanceEvaluation.CmdDescriptor> commands
protected static Cluster cluster
public static final Pattern LINE_PATTERN
public PerformanceEvaluation(Configuration c)
c
- Configuration objectprotected void addCommandDescriptor(Class<? extends org.apache.hadoop.hbase.rest.PerformanceEvaluation.Test> cmdClass, String name, String description)
protected HTableDescriptor getTableDescriptor()
protected byte[][] getSplits()
public static byte[] format(int number)
public static byte[] generateData(Random r, int length)
public static byte[] generateValue(Random r)
protected void printUsage()
protected void printUsage(String message)