Class DataIterator<T>

  • Type Parameters:
    T - is the output data type returned by this iterator.
    All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, java.util.Iterator<T>, CloseableIterator<T>

    @Internal
    public class DataIterator<T>
    extends java.lang.Object
    implements CloseableIterator<T>
    Flink data iterator that reads CombinedScanTask into a CloseableIterator
    • Method Detail

      • seek

        public void seek​(int startingFileOffset,
                         long startingRecordOffset)
        (startingFileOffset, startingRecordOffset) points to the next row that reader should resume from. E.g., if the seek position is (file=0, record=1), seek moves the iterator position to the 2nd row in file 0. When next() is called after seek, 2nd row from file 0 should be returned.
      • hasNext

        public boolean hasNext()
        Specified by:
        hasNext in interface java.util.Iterator<T>
      • next

        public T next()
        Specified by:
        next in interface java.util.Iterator<T>
      • currentFileHasNext

        public boolean currentFileHasNext()
      • close

        public void close()
                   throws java.io.IOException
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Throws:
        java.io.IOException
      • fileOffset

        public int fileOffset()
      • recordOffset

        public long recordOffset()