cascading.tap.hadoop.io
Class RecordReaderIterator
java.lang.Object
cascading.util.SingleValueIterator<Value>
cascading.util.SingleValueCloseableIterator<org.apache.hadoop.mapred.RecordReader>
cascading.tap.hadoop.io.RecordReaderIterator
- All Implemented Interfaces:
- cascading.util.CloseableIterator<org.apache.hadoop.mapred.RecordReader>, Closeable, Iterator<org.apache.hadoop.mapred.RecordReader>
public class RecordReaderIterator
- extends cascading.util.SingleValueCloseableIterator<org.apache.hadoop.mapred.RecordReader>
RecordReaderIterator is a utility class for handing off a single RecordReader
instance
via the Iterator
.
This class is frequently used with the TupleEntrySchemeIterator
where there is only
one RecordReader to iterate values over.
Fields inherited from class cascading.util.SingleValueIterator |
EMPTY, value |
Method Summary |
void |
close()
|
Methods inherited from class cascading.util.SingleValueCloseableIterator |
getCloseableInput |
Methods inherited from class cascading.util.SingleValueIterator |
hasNext, next, remove, reset |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RecordReaderIterator
public RecordReaderIterator(org.apache.hadoop.mapred.RecordReader reader)
close
public void close()
throws IOException
- Specified by:
close
in interface Closeable
- Specified by:
close
in class cascading.util.SingleValueCloseableIterator<org.apache.hadoop.mapred.RecordReader>
- Throws:
IOException
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.