cascading.tap.hadoop.io
Class HadoopTupleEntrySchemeIterator
java.lang.Object
cascading.tuple.TupleEntryIterator
cascading.tuple.TupleEntrySchemeIterator<JobConf,RecordReader>
cascading.tap.hadoop.io.HadoopTupleEntrySchemeIterator
- All Implemented Interfaces:
- Closeable, Iterator<cascading.tuple.TupleEntry>
public class HadoopTupleEntrySchemeIterator
- extends cascading.tuple.TupleEntrySchemeIterator<JobConf,RecordReader>
Methods inherited from class cascading.tuple.TupleEntrySchemeIterator |
close, getFlowProcess, hasNext, next, remove |
Methods inherited from class cascading.tuple.TupleEntryIterator |
getFields, getTupleEntry |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HadoopTupleEntrySchemeIterator
public HadoopTupleEntrySchemeIterator(cascading.flow.FlowProcess<JobConf> flowProcess,
cascading.tap.Tap parentTap,
RecordReader recordReader)
throws IOException
- Throws:
IOException
HadoopTupleEntrySchemeIterator
public HadoopTupleEntrySchemeIterator(cascading.flow.FlowProcess<JobConf> flowProcess,
cascading.scheme.Scheme scheme,
cascading.util.CloseableIterator<RecordReader> closeableIterator)
wrapInput
protected RecordReader wrapInput(RecordReader recordReader)
- Overrides:
wrapInput
in class cascading.tuple.TupleEntrySchemeIterator<JobConf,RecordReader>
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.