org.apache.paimon.reader

Interface FileRecordIterator<T>

Type Parameters:

T - The type of the record.

All Superinterfaces:

RecordReader.RecordIterator<T>

All Known Implementing Classes:

ApplyDeletionFileRecordIterator, ColumnarRowIterator, IteratorResultIterator

public interface FileRecordIterator<T>
extends RecordReader.RecordIterator<T>

Wrap RecordReader.RecordIterator to support returning the record's row position and file Path.

Method Summary

Modifier and Type	Method and Description
Path	filePath()
default FileRecordIterator<T>	filter(Filter<T> filter) Filters a RecordReader.RecordIterator.
long	returnedPosition() Get the row position of the row returned by RecordReader.RecordIterator.next().
default <R> FileRecordIterator<R>	transform(java.util.function.Function<T,R> function) Returns an iterator that applies function to each element.

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

next, releaseBatch

Method Detail

returnedPosition

long returnedPosition()

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

Returns:

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

filePath

Path filePath()

Returns:

the file path

transform

default <R> FileRecordIterator<R> transform(java.util.function.Function<T,R> function)

Description copied from interface: RecordReader.RecordIterator

Returns an iterator that applies function to each element.

Specified by:

transform in interface RecordReader.RecordIterator<T>

filter

default FileRecordIterator<T> filter(Filter<T> filter)

Description copied from interface: RecordReader.RecordIterator

Filters a RecordReader.RecordIterator.

Specified by:

filter in interface RecordReader.RecordIterator<T>