cascading.tap.hadoop.io
Class HadoopTupleEntrySchemeCollector

java.lang.Object
  extended by cascading.tuple.TupleEntryCollector
      extended by cascading.tuple.TupleEntrySchemeCollector<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.OutputCollector>
          extended by cascading.tap.hadoop.io.HadoopTupleEntrySchemeCollector

public class HadoopTupleEntrySchemeCollector
extends TupleEntrySchemeCollector<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.OutputCollector>

Class HadoopTupleEntrySchemeCollector is a kind of TupleEntryCollector that writes tuples to the resource managed by a particular Tap instance.


Field Summary
 
Fields inherited from class cascading.tuple.TupleEntrySchemeCollector
sinkCall
 
Fields inherited from class cascading.tuple.TupleEntryCollector
tupleEntry
 
Constructor Summary
HadoopTupleEntrySchemeCollector(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess, Tap<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector> tap)
           
HadoopTupleEntrySchemeCollector(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess, Tap<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector> tap, org.apache.hadoop.mapred.OutputCollector outputCollector)
           
 
Method Summary
protected  org.apache.hadoop.mapred.OutputCollector<?,?> wrapOutput(org.apache.hadoop.mapred.OutputCollector outputCollector)
           
 
Methods inherited from class cascading.tuple.TupleEntrySchemeCollector
add, add, close, collect, getFlowProcess, getOutput, prepare, setFields, setOutput
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

HadoopTupleEntrySchemeCollector

public HadoopTupleEntrySchemeCollector(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess,
                                       Tap<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector> tap)
                                throws IOException
Throws:
IOException

HadoopTupleEntrySchemeCollector

public HadoopTupleEntrySchemeCollector(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess,
                                       Tap<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector> tap,
                                       org.apache.hadoop.mapred.OutputCollector outputCollector)
                                throws IOException
Throws:
IOException
Method Detail

wrapOutput

protected org.apache.hadoop.mapred.OutputCollector<?,?> wrapOutput(org.apache.hadoop.mapred.OutputCollector outputCollector)
Overrides:
wrapOutput in class TupleEntrySchemeCollector<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.OutputCollector>


Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.