cascading.tap.hadoop.io
Class HadoopTupleEntrySchemeCollector
java.lang.Object
cascading.tuple.TupleEntryCollector
cascading.tuple.TupleEntrySchemeCollector<JobConf,OutputCollector>
cascading.tap.hadoop.io.HadoopTupleEntrySchemeCollector
public class HadoopTupleEntrySchemeCollector
- extends TupleEntrySchemeCollector<JobConf,OutputCollector>
Class HadoopTupleEntrySchemeCollector is a kind of TupleEntryCollector
that writes tuples to the resource managed by
a particular Tap
instance.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HadoopTupleEntrySchemeCollector
public HadoopTupleEntrySchemeCollector(FlowProcess<JobConf> flowProcess,
Tap<JobConf,RecordReader,OutputCollector> tap)
throws IOException
- Throws:
IOException
HadoopTupleEntrySchemeCollector
public HadoopTupleEntrySchemeCollector(FlowProcess<JobConf> flowProcess,
Tap<JobConf,RecordReader,OutputCollector> tap,
OutputCollector outputCollector)
throws IOException
- Throws:
IOException
wrapOutput
protected OutputCollector<?,?> wrapOutput(OutputCollector outputCollector)
- Overrides:
wrapOutput
in class TupleEntrySchemeCollector<JobConf,OutputCollector>
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.