cascading.tap.hadoop.io
Class HadoopTupleEntrySchemeIterator

java.lang.Object
  cascading.tuple.TupleEntryIterator
      cascading.tuple.TupleEntrySchemeIterator<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader>
          cascading.tap.hadoop.io.HadoopTupleEntrySchemeIterator

All Implemented Interfaces:

Closeable, Iterator<TupleEntry>

public class HadoopTupleEntrySchemeIterator
extends TupleEntrySchemeIterator<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader>

Constructor Summary

HadoopTupleEntrySchemeIterator(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess, Scheme scheme, cascading.util.CloseableIterator<org.apache.hadoop.mapred.RecordReader> closeableIterator)

HadoopTupleEntrySchemeIterator(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess, Tap parentTap, org.apache.hadoop.mapred.RecordReader recordReader)

Method Summary

protected org.apache.hadoop.mapred.RecordReader

wrapInput(org.apache.hadoop.mapred.RecordReader 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

Constructor Detail

HadoopTupleEntrySchemeIterator

public HadoopTupleEntrySchemeIterator(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess,
                                      Tap parentTap,
                                      org.apache.hadoop.mapred.RecordReader recordReader)
                               throws IOException

Throws:

IOException

HadoopTupleEntrySchemeIterator

public HadoopTupleEntrySchemeIterator(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess,
                                      Scheme scheme,
                                      cascading.util.CloseableIterator<org.apache.hadoop.mapred.RecordReader> closeableIterator)

Method Detail

wrapInput

protected org.apache.hadoop.mapred.RecordReader wrapInput(org.apache.hadoop.mapred.RecordReader recordReader)

Overrides:

wrapInput in class TupleEntrySchemeIterator<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader>