T
- is the output data type returned by this iterator.@Internal public class DataIterator<T> extends java.lang.Object implements CloseableIterator<T>
CombinedScanTask
into a CloseableIterator
Constructor and Description |
---|
DataIterator(FileScanTaskReader<T> fileScanTaskReader,
CombinedScanTask task,
FileIO io,
EncryptionManager encryption) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
currentFileHasNext() |
int |
fileOffset() |
boolean |
hasNext() |
T |
next() |
long |
recordOffset() |
void |
seek(int startingFileOffset,
long startingRecordOffset)
(startingFileOffset, startingRecordOffset) points to the next row that reader should resume
from.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
count, empty, transform, withClose
public DataIterator(FileScanTaskReader<T> fileScanTaskReader, CombinedScanTask task, FileIO io, EncryptionManager encryption)
public void seek(int startingFileOffset, long startingRecordOffset)
public boolean hasNext()
hasNext
in interface java.util.Iterator<T>
public boolean currentFileHasNext()
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
public int fileOffset()
public long recordOffset()