com.datasalt.pangool.tuplemr.mapred
Class SimpleCombiner

java.lang.Object
  org.apache.hadoop.mapreduce.Reducer<DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable,DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable>
      com.datasalt.pangool.tuplemr.mapred.SimpleCombiner

public class SimpleCombiner
extends org.apache.hadoop.mapreduce.Reducer<DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable,DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable>

Nested Class Summary

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

org.apache.hadoop.mapreduce.Reducer.Context

Field Summary

static String

CONF_COMBINER_HANDLER

Constructor Summary

SimpleCombiner()

Method Summary

void	cleanup(org.apache.hadoop.mapreduce.Reducer.Context context)
void	reduce(DatumWrapper<ITuple> key, Iterable<org.apache.hadoop.io.NullWritable> values, org.apache.hadoop.mapreduce.Reducer.Context context)
void	setup(org.apache.hadoop.mapreduce.Reducer.Context context)

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

run

Methods inherited from class java.lang.Object

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

Field Detail

CONF_COMBINER_HANDLER

public static final String CONF_COMBINER_HANDLER

Constructor Detail

SimpleCombiner

public SimpleCombiner()

Method Detail

setup

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

Overrides:

setup in class org.apache.hadoop.mapreduce.Reducer<DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable,DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable>

Throws:

IOException

InterruptedException

cleanup

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

Overrides:

cleanup in class org.apache.hadoop.mapreduce.Reducer<DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable,DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable>

Throws:

IOException

InterruptedException

reduce

public final void reduce(DatumWrapper<ITuple> key,
                         Iterable<org.apache.hadoop.io.NullWritable> values,
                         org.apache.hadoop.mapreduce.Reducer.Context context)
                  throws IOException,
                         InterruptedException

Overrides:

reduce in class org.apache.hadoop.mapreduce.Reducer<DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable,DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable>

Throws:

IOException

InterruptedException