com.datasalt.pangool.tuplemr
Class IdentityTupleReducer

java.lang.Object
  extended by com.datasalt.pangool.tuplemr.TupleReducer<ITuple,org.apache.hadoop.io.NullWritable>
      extended by com.datasalt.pangool.tuplemr.IdentityTupleReducer
All Implemented Interfaces:
Serializable

public class IdentityTupleReducer
extends TupleReducer<ITuple,org.apache.hadoop.io.NullWritable>

See Also:
Serialized Form

Nested Class Summary
 
Nested classes/interfaces inherited from class com.datasalt.pangool.tuplemr.TupleReducer
TupleReducer.Collector, TupleReducer.CombinerCollector, TupleReducer.StaticCollector<OUTPUT_KEY,OUTPUT_VALUE,CONTEXT_OUTPUT_KEY,CONTEXT_OUTPUT_VALUE>, TupleReducer.TupleMRContext
 
Constructor Summary
IdentityTupleReducer()
           
 
Method Summary
 void reduce(ITuple group, Iterable<ITuple> tuples, TupleReducer.TupleMRContext context, TupleReducer.Collector collector)
          This method is called with an iterable that contains all the tuples that have been grouped by the fields defined in TupleMRConfigBuilder.setGroupByFields(String...)
 
Methods inherited from class com.datasalt.pangool.tuplemr.TupleReducer
cleanup, setup
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

IdentityTupleReducer

public IdentityTupleReducer()
Method Detail

reduce

public void reduce(ITuple group,
                   Iterable<ITuple> tuples,
                   TupleReducer.TupleMRContext context,
                   TupleReducer.Collector collector)
            throws IOException,
                   InterruptedException,
                   TupleMRException
Description copied from class: TupleReducer
This method is called with an iterable that contains all the tuples that have been grouped by the fields defined in TupleMRConfigBuilder.setGroupByFields(String...)

Overrides:
reduce in class TupleReducer<ITuple,org.apache.hadoop.io.NullWritable>
tuples - Iterable that contains all the tuples from a group
context - The reducer context as in Reducer
Throws:
IOException
InterruptedException
TupleMRException


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