com.datasalt.pangool.tuplemr
Class TupleMapper.Collector

java.lang.Object
  extended by com.datasalt.pangool.tuplemr.MultipleOutputsCollector
      extended by com.datasalt.pangool.tuplemr.TupleMapper.Collector
Enclosing class:
TupleMapper<INPUT_KEY,INPUT_VALUE>

public static class TupleMapper.Collector
extends MultipleOutputsCollector

Class for collecting data inside a TupleMapper.


Field Summary
 
Fields inherited from class com.datasalt.pangool.tuplemr.MultipleOutputsCollector
multipleOutputs
 
Method Summary
 void write(ITuple tuple)
           
 
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
 

Method Detail

write

public void write(ITuple tuple)
           throws IOException,
                  InterruptedException
Throws:
IOException
InterruptedException


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