com.datasalt.pangool.tuplemr
Class TupleReducer.Collector

java.lang.Object
  com.datasalt.pangool.tuplemr.MultipleOutputsCollector
      com.datasalt.pangool.tuplemr.TupleReducer.StaticCollector<OUTPUT_KEY,OUTPUT_VALUE,Object,Object>
          com.datasalt.pangool.tuplemr.TupleReducer.Collector

Direct Known Subclasses:

TupleReducer.CombinerCollector

Enclosing class:

TupleReducer<OUTPUT_KEY,OUTPUT_VALUE>

public class TupleReducer.Collector
extends TupleReducer.StaticCollector<OUTPUT_KEY,OUTPUT_VALUE,Object,Object>

Base class for collecting data from a TupleReducer in the reduce phase. This non static inner class is created to eliminate the need in of the extended TupleReducer methods to specify the generic types for the Collector meanwhile keeping generics.

Field Summary

Fields inherited from class com.datasalt.pangool.tuplemr.TupleReducer.StaticCollector

context

Fields inherited from class com.datasalt.pangool.tuplemr.MultipleOutputsCollector

multipleOutputs

Constructor Summary

TupleReducer.Collector(org.apache.hadoop.mapreduce.ReduceContext<DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable,Object,Object> context)

Method Summary

Methods inherited from class com.datasalt.pangool.tuplemr.TupleReducer.StaticCollector

write

Methods inherited from class com.datasalt.pangool.tuplemr.MultipleOutputsCollector

close, getNamedOutput, write

Methods inherited from class java.lang.Object

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

Constructor Detail

TupleReducer.Collector

public TupleReducer.Collector(org.apache.hadoop.mapreduce.ReduceContext<DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable,Object,Object> context)