com.datasalt.pangool.tuplemr.mapred
Class SimpleReducer<OUTPUT_KEY,OUTPUT_VALUE>

java.lang.Object
  extended by org.apache.hadoop.mapreduce.Reducer<DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable,OUTPUT_KEY,OUTPUT_VALUE>
      extended by com.datasalt.pangool.tuplemr.mapred.SimpleReducer<OUTPUT_KEY,OUTPUT_VALUE>

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

This is a proxy Reducer implementation that delegates its funcionality to a TupleReducer instance configured by TupleMRBuilder.setTupleReducer(TupleReducer)


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_REDUCER_HANDLER
           
 
Constructor Summary
SimpleReducer()
           
 
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_REDUCER_HANDLER

public static final String CONF_REDUCER_HANDLER
Constructor Detail

SimpleReducer

public SimpleReducer()
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,OUTPUT_KEY,OUTPUT_VALUE>
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,OUTPUT_KEY,OUTPUT_VALUE>
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,OUTPUT_KEY,OUTPUT_VALUE>
Throws:
IOException
InterruptedException


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