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 java.util.Map<java.lang.String,org.apache.hadoop.hbase.rest.PerformanceEvaluation.CmdDescriptor> |
commands |
static byte[] |
FAMILY_NAME |
static java.util.regex.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(java.lang.Class<? extends org.apache.hadoop.hbase.rest.PerformanceEvaluation.Test> cmdClass,
java.lang.String name,
java.lang.String description) |
static byte[] |
format(int number) |
static byte[] |
generateData(java.util.Random r,
int length) |
static byte[] |
generateValue(java.util.Random r) |
protected byte[][] |
getSplits()
Generates splits based on total number of rows and specified split regions
|
protected HTableDescriptor |
getTableDescriptor() |
static void |
main(java.lang.String[] args) |
protected void |
printUsage() |
protected void |
printUsage(java.lang.String message) |
int |
run(java.lang.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 java.util.Map<java.lang.String,org.apache.hadoop.hbase.rest.PerformanceEvaluation.CmdDescriptor> commands
protected static Cluster cluster
public static final java.util.regex.Pattern LINE_PATTERN
public PerformanceEvaluation(Configuration c)
c
- Configuration objectprotected void addCommandDescriptor(java.lang.Class<? extends org.apache.hadoop.hbase.rest.PerformanceEvaluation.Test> cmdClass, java.lang.String name, java.lang.String description)
protected HTableDescriptor getTableDescriptor()
protected byte[][] getSplits()
public static byte[] format(int number)
public static byte[] generateData(java.util.Random r, int length)
public static byte[] generateValue(java.util.Random r)
protected void printUsage()
protected void printUsage(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
args
- java.lang.Exception