cascading.tap.hadoop.io
Class HadoopTupleEntrySchemeIterator

java.lang.Object
  extended by cascading.tuple.TupleEntryIterator
      extended by cascading.tuple.TupleEntrySchemeIterator<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader>
          extended by 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>


Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.