public class MultiRecordReaderIterator extends java.lang.Object implements CloseableIterator<RecordReader>
CloseableIterator
. It is returned by Tap
instances when
opening the taps resource for reading.Constructor and Description |
---|
MultiRecordReaderIterator(FlowProcess<? extends Configuration> flowProcess,
Tap tap)
Constructor TapIterator creates a new TapIterator instance.
|
public MultiRecordReaderIterator(FlowProcess<? extends Configuration> flowProcess, Tap tap) throws java.io.IOException
java.io.IOException
- whenpublic boolean hasNext()
Tuple
instances available.hasNext
in interface java.util.Iterator<RecordReader>
public RecordReader next()
Tuple
.next
in interface java.util.Iterator<RecordReader>
public void remove()
remove
in interface java.util.Iterator<RecordReader>
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.