org.apache.paimon.data.columnar

Class ColumnarRowIterator

java.lang.Object

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

org.apache.paimon.data.columnar.ColumnarRowIterator

All Implemented Interfaces:

FileRecordIterator<InternalRow>, RecordReader.RecordIterator<InternalRow>, VectorizedRecordIterator

public class ColumnarRowIterator
extends RecyclableIterator<InternalRow>
implements FileRecordIterator<InternalRow>, VectorizedRecordIterator

A RecordReader.RecordIterator that returns InternalRows. The next row is set by ColumnarRow.setRowId(int).

Constructor Summary

Constructors

Constructor and Description
ColumnarRowIterator(Path filePath, ColumnarRow row, Runnable recycler)

Method Summary

Modifier and Type	Method and Description
VectorizedColumnBatch	batch()
ColumnarRowIterator	copy(ColumnVector[] vectors)
Path	filePath()
ColumnarRowIterator	mapping(PartitionInfo partitionInfo, int[] indexMapping)
InternalRow	next() Gets the next record from the iterator.
void	reset(long nextFilePos)
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

ColumnarRowIterator

public ColumnarRowIterator(Path filePath,
                           ColumnarRow row,
                           @Nullable
                           Runnable recycler)

Method Detail

reset

public void reset(long nextFilePos)

next

@Nullable
public InternalRow next()

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>

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

copy

public ColumnarRowIterator copy(ColumnVector[] vectors)

mapping

public ColumnarRowIterator mapping(@Nullable
                                   PartitionInfo partitionInfo,
                                   @Nullable
                                   int[] indexMapping)

batch

public VectorizedColumnBatch batch()

Specified by:

batch in interface VectorizedRecordIterator