cascading.tap.hadoop.io
Class HadoopTupleEntrySchemeCollector
java.lang.Object
cascading.tuple.TupleEntryCollector
cascading.tuple.TupleEntrySchemeCollector<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.OutputCollector>
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.
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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
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.