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.

Author:

"Matthew Hayes"

Constructor Summary

ObjectReducer()

Method Summary

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