org.apache.accumulo.test.randomwalk.sequential

Class MapRedVerifyTool.SeqReduceClass

java.lang.Object

org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.Text,Mutation>

org.apache.accumulo.test.randomwalk.sequential.MapRedVerifyTool.SeqReduceClass

Enclosing class:

MapRedVerifyTool

public static class MapRedVerifyTool.SeqReduceClass
extends org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.Text,Mutation>

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
MapRedVerifyTool.SeqReduceClass()

Method Summary

Methods

Modifier and Type	Method and Description
void	reduce(org.apache.hadoop.io.NullWritable ignore, Iterable<org.apache.hadoop.io.IntWritable> values, org.apache.hadoop.mapreduce.Reducer.Context output)
void	writeMutation(org.apache.hadoop.mapreduce.Reducer.Context output, int start, int end)

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

MapRedVerifyTool.SeqReduceClass

public MapRedVerifyTool.SeqReduceClass()

Method Detail

reduce

public void reduce(org.apache.hadoop.io.NullWritable ignore,
          Iterable<org.apache.hadoop.io.IntWritable> values,
          org.apache.hadoop.mapreduce.Reducer.Context output)
            throws IOException,
                   InterruptedException

Overrides:

reduce in class org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.Text,Mutation>

Throws:

IOException

InterruptedException

writeMutation

public void writeMutation(org.apache.hadoop.mapreduce.Reducer.Context output,
                 int start,
                 int end)
                   throws IOException,
                          InterruptedException

Throws:

IOException

InterruptedException