org.apache.hadoop.tools.dynamometer.workloadgenerator.audit

Class AuditReplayReducer

java.lang.Object

org.apache.hadoop.mapreduce.Reducer<UserCommandKey,CountTimeWritable,UserCommandKey,CountTimeWritable>

org.apache.hadoop.tools.dynamometer.workloadgenerator.audit.AuditReplayReducer

public class AuditReplayReducer
extends org.apache.hadoop.mapreduce.Reducer<UserCommandKey,CountTimeWritable,UserCommandKey,CountTimeWritable>

AuditReplayReducer aggregates the returned latency values from AuditReplayMapper and sums them up by UserCommandKey, which combines the user's id that ran the command and the type of the command (READ/WRITE).

Nested Class Summary

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

org.apache.hadoop.mapreduce.Reducer.Context

Constructor Summary

Constructors

Constructor and Description
AuditReplayReducer()

Method Summary

Modifier and Type	Method and Description
protected void	reduce(UserCommandKey key, Iterable<CountTimeWritable> values, org.apache.hadoop.mapreduce.Reducer.Context context)

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

cleanup, run, setup

Methods inherited from class java.lang.Object

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

Constructor Detail

AuditReplayReducer

public AuditReplayReducer()

Method Detail

reduce

protected void reduce(UserCommandKey key,
                      Iterable<CountTimeWritable> values,
                      org.apache.hadoop.mapreduce.Reducer.Context context)
               throws IOException,
                      InterruptedException

Overrides:

reduce in class org.apache.hadoop.mapreduce.Reducer<UserCommandKey,CountTimeWritable,UserCommandKey,CountTimeWritable>

Throws:

IOException

InterruptedException