Package org.apache.hadoop.hbase

Class PerformanceEvaluation.EvaluationMapTask

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>

org.apache.hadoop.hbase.PerformanceEvaluation.EvaluationMapTask

Enclosing class:

PerformanceEvaluation

public static class PerformanceEvaluation.EvaluationMapTask
extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>

MapReduce job that runs a performance evaluation client in each map task.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper

org.apache.hadoop.mapreduce.Mapper.Context

Field Summary

Fields

Modifier and Type	Field	Description
private Class<? extends PerformanceEvaluation.Test>	cmd
static final String	CMD_KEY	configuration parameter name that contains the command
static final String	PE_KEY	configuration parameter name that contains the PE impl

Constructor Summary

Constructors

Constructor	Description
EvaluationMapTask()

Method Summary

Modifier and Type	Method	Description
private <Type> Class<? extends Type>	forName(String className, Class<Type> type)
protected void	map(org.apache.hadoop.io.LongWritable key, org.apache.hadoop.io.Text value, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
protected void	setup(org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)

Methods inherited from class org.apache.hadoop.mapreduce.Mapper

cleanup, run

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CMD_KEY

public static final String CMD_KEY

configuration parameter name that contains the command

See Also:

• Constant Field Values

PE_KEY

public static final String PE_KEY

configuration parameter name that contains the PE impl

See Also:

• Constant Field Values

cmd

private Class<? extends PerformanceEvaluation.Test> cmd

Constructor Details

EvaluationMapTask

public EvaluationMapTask()

Method Details

setup

protected void setup(org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
              throws IOException,
InterruptedException

Overrides:

setup in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>

Throws:

IOException

InterruptedException

forName

private <Type> Class<? extends Type> forName(String className,
 Class<Type> type)

map

protected void map(org.apache.hadoop.io.LongWritable key,
 org.apache.hadoop.io.Text value,
 org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)
            throws IOException,
InterruptedException

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>

Throws:

IOException

InterruptedException