com.datasalt.pangool.tuplemr
Class TupleReducer.CombinerCollector

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
              extended by com.datasalt.pangool.tuplemr.TupleReducer.CombinerCollector
Enclosing class:
TupleReducer<OUTPUT_KEY,OUTPUT_VALUE>

public class TupleReducer.CombinerCollector
extends TupleReducer.Collector

Class for collecting data from a TupleReducer in the combining phase


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.CombinerCollector(org.apache.hadoop.mapreduce.ReduceContext<DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable,Object,Object> context)
          This non static inner class is created to eliminate the need in of the extended GroupHandler methods to specify the generic types for the Collector meanwhile keeping generics.
 
Method Summary
 void write(OUTPUT_KEY tuple, OUTPUT_VALUE ignored)
          Overrided write for wrapping tuples into DatumWrappers.
 
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.CombinerCollector

public TupleReducer.CombinerCollector(org.apache.hadoop.mapreduce.ReduceContext<DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable,Object,Object> context)
This non static inner class is created to eliminate the need in of the extended GroupHandler methods to specify the generic types for the Collector meanwhile keeping generics.

Method Detail

write

public void write(OUTPUT_KEY tuple,
                  OUTPUT_VALUE ignored)
           throws IOException,
                  InterruptedException
Overrided write for wrapping tuples into DatumWrappers.

Overrides:
write in class TupleReducer.StaticCollector<OUTPUT_KEY,OUTPUT_VALUE,Object,Object>
Throws:
IOException
InterruptedException


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