cgl.imr.base.impl
Class GenericCombiner

java.lang.Object
  extended by cgl.imr.base.impl.GenericCombiner
All Implemented Interfaces:
Combiner

public class GenericCombiner
extends Object
implements Combiner

A generic combiner that can be used by any MapReduce computation. Simply groups the results received from the Reduce tasks into a map and returns it.


Constructor Summary
GenericCombiner()
           
 
Method Summary
 void close()
           
 void combine(Map<Key,Value> keyValues)
          Should perform the user defined combine operation for the passed pairs.
 void configure(JobConf jobConf)
          Use to configure a combine task for static data/or other configurations.
 Map<Key,Value> getResults()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

GenericCombiner

public GenericCombiner()
Method Detail

close

public void close()
           throws TwisterException
Throws:
TwisterException

combine

public void combine(Map<Key,Value> keyValues)
Description copied from interface: Combiner
Should perform the user defined combine operation for the passed pairs.

Specified by:
combine in interface Combiner
Parameters:
keyValues - A map of pairs.

configure

public void configure(JobConf jobConf)
               throws TwisterException
Description copied from interface: Combiner
Use to configure a combine task for static data/or other configurations.

Specified by:
configure in interface Combiner
Parameters:
jobConf - Job configuration object.
Throws:
TwisterException

getResults

public Map<Key,Value> getResults()


For comments and suggestions please send e-mail to