org.apache.paimon.utils

Class IteratorResultIterator

java.lang.Object

org.apache.paimon.utils.RecyclableIterator<InternalRow>

org.apache.paimon.utils.IteratorResultIterator

All Implemented Interfaces:

FileRecordIterator<InternalRow>, RecordReader.RecordIterator<InternalRow>

public final class IteratorResultIterator
extends RecyclableIterator<InternalRow>
implements FileRecordIterator<InternalRow>

A simple RecordReader.RecordIterator that returns the elements of an iterator.

Constructor Summary

Constructors

Constructor and Description
IteratorResultIterator(IteratorWithException<InternalRow,IOException> records, Runnable recycler, Path filePath, long pos)

Method Summary

Modifier and Type	Method and Description
Path	filePath()
InternalRow	next() Gets the next record from the iterator.
long	returnedPosition() Get the row position of the row returned by RecordReader.RecordIterator.next().

Methods inherited from class org.apache.paimon.utils.RecyclableIterator

releaseBatch

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.reader.FileRecordIterator

filter, transform

Methods inherited from interface org.apache.paimon.reader.RecordReader.RecordIterator

releaseBatch

Constructor Detail

IteratorResultIterator

public IteratorResultIterator(IteratorWithException<InternalRow,IOException> records,
                              @Nullable
                              Runnable recycler,
                              Path filePath,
                              long pos)

Method Detail

next

@Nullable
public InternalRow next()
                           throws IOException

Description copied from interface: RecordReader.RecordIterator

Gets the next record from the iterator. Returns null if this iterator has no more elements.

Specified by:

next in interface RecordReader.RecordIterator<InternalRow>

Throws:

IOException

returnedPosition

public long returnedPosition()

Description copied from interface: FileRecordIterator

Get the row position of the row returned by RecordReader.RecordIterator.next().

Specified by:

returnedPosition in interface FileRecordIterator<InternalRow>

Returns:

the row position from 0 to the number of rows in the file

filePath

public Path filePath()

Specified by:

filePath in interface FileRecordIterator<InternalRow>

Returns:

the file path