Package org.apache.hadoop.hbase.rest

Class PerformanceEvaluation.EvaluationMapTask

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,PerformanceEvaluation.PeInputSplit,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>

org.apache.hadoop.hbase.rest.PerformanceEvaluation.EvaluationMapTask

Enclosing class:

PerformanceEvaluation

public static class PerformanceEvaluation.EvaluationMapTask
extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,PerformanceEvaluation.PeInputSplit,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
private PerformanceEvaluation	pe
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.NullWritable key, PerformanceEvaluation.PeInputSplit value, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,PerformanceEvaluation.PeInputSplit,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.NullWritable,PerformanceEvaluation.PeInputSplit,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

pe

private PerformanceEvaluation pe

Constructor Details

EvaluationMapTask

public EvaluationMapTask()

Method Details

setup

protected void setup(org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,PerformanceEvaluation.PeInputSplit,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>.org.apache.hadoop.mapreduce.Mapper.Context context)

Overrides:

setup in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,PerformanceEvaluation.PeInputSplit,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>

forName

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

map

protected void map(org.apache.hadoop.io.NullWritable key,
 PerformanceEvaluation.PeInputSplit value,
 org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,PerformanceEvaluation.PeInputSplit,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.NullWritable,PerformanceEvaluation.PeInputSplit,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.LongWritable>

Throws:

IOException

InterruptedException