com.datasalt.pangool.tuplemr.mapred
Class SimpleCombiner

java.lang.Object
  extended by org.apache.hadoop.mapreduce.Reducer<DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable,DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable>
      extended by 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


Copyright © –2014 Datasalt Systems S.L.. All rights reserved.