org.apache.hadoop.chukwa.util
Class ConstRateValidator.ReduceClass

java.lang.Object
  org.apache.hadoop.mapreduce.Reducer<ConstRateValidator.ByteRange,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
      org.apache.hadoop.chukwa.util.ConstRateValidator.ReduceClass

Enclosing class:

ConstRateValidator

public static class ConstRateValidator.ReduceClass
extends org.apache.hadoop.mapreduce.Reducer<ConstRateValidator.ByteRange,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Nested Class Summary

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

org.apache.hadoop.mapreduce.Reducer.Context

Constructor Summary

ConstRateValidator.ReduceClass()

Method Summary

protected void	cleanup(org.apache.hadoop.mapreduce.Reducer.Context context)
void	printEndOfStream(org.apache.hadoop.mapreduce.Reducer.Context context)
protected void	reduce(ConstRateValidator.ByteRange b, Iterable<org.apache.hadoop.io.NullWritable> vals, org.apache.hadoop.mapreduce.Reducer.Context context)

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

run, setup

Methods inherited from class java.lang.Object

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

Constructor Detail

ConstRateValidator.ReduceClass

public ConstRateValidator.ReduceClass()

Method Detail

reduce

protected void reduce(ConstRateValidator.ByteRange b,
                      Iterable<org.apache.hadoop.io.NullWritable> vals,
                      org.apache.hadoop.mapreduce.Reducer.Context context)

Overrides:

reduce in class org.apache.hadoop.mapreduce.Reducer<ConstRateValidator.ByteRange,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

cleanup

protected void cleanup(org.apache.hadoop.mapreduce.Reducer.Context context)
                throws IOException,
                       InterruptedException

Overrides:

cleanup in class org.apache.hadoop.mapreduce.Reducer<ConstRateValidator.ByteRange,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

Throws:

IOException

InterruptedException

printEndOfStream

public void printEndOfStream(org.apache.hadoop.mapreduce.Reducer.Context context)
                      throws IOException,
                             InterruptedException

Throws:

IOException

InterruptedException