public class MultiRecordReaderIterator extends 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 IOException
IOException
- whenpublic boolean hasNext()
Tuple
instances available.hasNext
in interface Iterator<RecordReader>
public RecordReader next()
Tuple
.next
in interface Iterator<RecordReader>
public void remove()
remove
in interface Iterator<RecordReader>
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.