datafu.hourglass.mapreduce

Class ObjectReducer

java.lang.Object

datafu.hourglass.mapreduce.ObjectProcessor

datafu.hourglass.mapreduce.ObjectReducer

Direct Known Subclasses:

CollapsingCombiner, CollapsingReducer, PartitioningCombiner, PartitioningReducer

public abstract class ObjectReducer
extends ObjectProcessor

Defines the interface for combiner and reducer implementations that DelegatingCombiner and DelegatingReducer delegate to.

Constructor Summary

Constructors

Constructor and Description
ObjectReducer()

Method Summary

Methods

Modifier and Type	Method and Description
abstract void	reduce(java.lang.Object key, java.lang.Iterable<java.lang.Object> values, org.apache.hadoop.mapreduce.ReduceContext<java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object> context)

Methods inherited from class datafu.hourglass.mapreduce.ObjectProcessor

close, getContext, setContext

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectReducer

public ObjectReducer()

Method Detail

reduce

public abstract void reduce(java.lang.Object key,
          java.lang.Iterable<java.lang.Object> values,
          org.apache.hadoop.mapreduce.ReduceContext<java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object> context)
                     throws java.io.IOException,
                            java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException