com.datasalt.pangool.tuplemr
Class TupleReducer.StaticCollector<OUTPUT_KEY,OUTPUT_VALUE,CONTEXT_OUTPUT_KEY,CONTEXT_OUTPUT_VALUE>

java.lang.Object
  extended by com.datasalt.pangool.tuplemr.MultipleOutputsCollector
      extended by com.datasalt.pangool.tuplemr.TupleReducer.StaticCollector<OUTPUT_KEY,OUTPUT_VALUE,CONTEXT_OUTPUT_KEY,CONTEXT_OUTPUT_VALUE>
Direct Known Subclasses:
TupleReducer.Collector
Enclosing class:
TupleReducer<OUTPUT_KEY,OUTPUT_VALUE>

public static class TupleReducer.StaticCollector<OUTPUT_KEY,OUTPUT_VALUE,CONTEXT_OUTPUT_KEY,CONTEXT_OUTPUT_VALUE>
extends MultipleOutputsCollector

A base class for the TupleReducer.Collector


Field Summary
protected  org.apache.hadoop.mapreduce.ReduceContext<DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable,CONTEXT_OUTPUT_KEY,CONTEXT_OUTPUT_VALUE> context
           
 
Fields inherited from class com.datasalt.pangool.tuplemr.MultipleOutputsCollector
multipleOutputs
 
Constructor Summary
TupleReducer.StaticCollector(org.apache.hadoop.mapreduce.ReduceContext<DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable,CONTEXT_OUTPUT_KEY,CONTEXT_OUTPUT_VALUE> context)
           
 
Method Summary
 void write(OUTPUT_KEY key, OUTPUT_VALUE value)
           
 
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
 

Field Detail

context

protected org.apache.hadoop.mapreduce.ReduceContext<DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable,CONTEXT_OUTPUT_KEY,CONTEXT_OUTPUT_VALUE> context
Constructor Detail

TupleReducer.StaticCollector

public TupleReducer.StaticCollector(org.apache.hadoop.mapreduce.ReduceContext<DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable,CONTEXT_OUTPUT_KEY,CONTEXT_OUTPUT_VALUE> context)
Method Detail

write

public void write(OUTPUT_KEY key,
                  OUTPUT_VALUE value)
           throws IOException,
                  InterruptedException
Throws:
IOException
InterruptedException


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