org.apache.paimon.reader

Interface RecordReader.RecordIterator<T>

All Known Subinterfaces:

FileRecordIterator<T>, VectorizedRecordIterator

All Known Implementing Classes:

ApplyDeletionFileRecordIterator, ColumnarRowIterator, IteratorResultIterator, RecyclableIterator, ResetRowKindRecordIterator, ValueContentRowDataRecordIterator

Enclosing interface:

RecordReader<T>

public static interface RecordReader.RecordIterator<T>

An internal iterator interface which presents a more restrictive API than Iterator.

Method Summary

Modifier and Type	Method and Description
default RecordReader.RecordIterator<T>	filter(Filter<T> filter) Filters a RecordReader.RecordIterator.
T	next() Gets the next record from the iterator.
void	releaseBatch() Releases the batch that this iterator iterated over.
default <R> RecordReader.RecordIterator<R>	transform(java.util.function.Function<T,R> function) Returns an iterator that applies function to each element.

Method Detail

next

@Nullable
T next()
          throws IOException

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

Throws:

IOException

releaseBatch

void releaseBatch()

Releases the batch that this iterator iterated over. This is not supposed to close the reader and its resources, but is simply a signal that this iterator is not used anymore. This method can be used as a hook to recycle/reuse heavyweight object structures.

transform

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

Returns an iterator that applies function to each element.

filter

default RecordReader.RecordIterator<T> filter(Filter<T> filter)

Filters a RecordReader.RecordIterator.