com.datasalt.pangool.tuplemr
Class TupleReducer.Collector

java.lang.Object
  extended by com.datasalt.pangool.tuplemr.MultipleOutputsCollector
      extended by com.datasalt.pangool.tuplemr.TupleReducer.StaticCollector<OUTPUT_KEY,OUTPUT_VALUE,Object,Object>
          extended by 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)


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