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 cascading.tuple.TupleEntrySchemeCollector<JobConf,OutputCollector>
Class HadoopTupleEntrySchemeCollector is a kind of TupleEntryCollector
that writes tuples to the resource managed by
a particular Tap
instance.
Fields inherited from class cascading.tuple.TupleEntrySchemeCollector |
sinkCall |
Fields inherited from class cascading.tuple.TupleEntryCollector |
tupleEntry |
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 |
HadoopTupleEntrySchemeCollector
public HadoopTupleEntrySchemeCollector(cascading.flow.FlowProcess<JobConf> flowProcess,
cascading.tap.Tap<JobConf,RecordReader,OutputCollector> tap)
throws IOException
- Throws:
IOException
HadoopTupleEntrySchemeCollector
public HadoopTupleEntrySchemeCollector(cascading.flow.FlowProcess<JobConf> flowProcess,
cascading.tap.Tap<JobConf,RecordReader,OutputCollector> tap,
OutputCollector outputCollector)
throws IOException
- Throws:
IOException
wrapOutput
protected OutputCollector<?,?> wrapOutput(OutputCollector outputCollector)
- Overrides:
wrapOutput
in class cascading.tuple.TupleEntrySchemeCollector<JobConf,OutputCollector>
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.