com.datasalt.pangool.tuplemr
Class MultipleOutputsCollector

java.lang.Object
  extended by com.datasalt.pangool.tuplemr.MultipleOutputsCollector
Direct Known Subclasses:
TupleMapper.Collector, TupleReducer.StaticCollector

public class MultipleOutputsCollector
extends Object


Field Summary
protected  PangoolMultipleOutputs multipleOutputs
           
 
Constructor Summary
MultipleOutputsCollector(org.apache.hadoop.mapreduce.MapContext context)
           
MultipleOutputsCollector(org.apache.hadoop.mapreduce.ReduceContext context)
           
 
Method Summary
 void close()
           
<K,V> org.apache.hadoop.mapreduce.RecordWriter<K,V>
getNamedOutput(String namedOutput)
           
<K,V> void
write(String namedOutput, K key, V value)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

multipleOutputs

protected PangoolMultipleOutputs multipleOutputs
Constructor Detail

MultipleOutputsCollector

public MultipleOutputsCollector(org.apache.hadoop.mapreduce.MapContext context)

MultipleOutputsCollector

public MultipleOutputsCollector(org.apache.hadoop.mapreduce.ReduceContext context)
Method Detail

getNamedOutput

public <K,V> org.apache.hadoop.mapreduce.RecordWriter<K,V> getNamedOutput(String namedOutput)
                                                             throws IOException,
                                                                    InterruptedException
Throws:
IOException
InterruptedException

write

public <K,V> void write(String namedOutput,
                        K key,
                        V value)
           throws IOException,
                  InterruptedException
Throws:
IOException
InterruptedException

close

public void close()
           throws IOException,
                  InterruptedException
Throws:
IOException
InterruptedException


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