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>

Direct Known Subclasses:

VectorizedRowIterator

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

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

Field Summary

Fields

Modifier and Type	Field and Description
protected Path	filePath
protected int	index
protected int	num
protected LongIterator	positionIterator
protected Runnable	recycler
protected long	returnedPosition
protected int	returnedPositionIndex
protected ColumnarRow	row

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected 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)
void	reset(LongIterator positions)
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

Field Detail

filePath

protected final Path filePath

row

protected final ColumnarRow row

recycler

protected final Runnable recycler

num

protected int num

index

protected int index

returnedPositionIndex

protected int returnedPositionIndex

returnedPosition

protected long returnedPosition

positionIterator

protected LongIterator positionIterator

Constructor Detail

ColumnarRowIterator

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

Method Detail

reset

public void reset(long nextFilePos)

reset

public void reset(LongIterator positions)

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

protected ColumnarRowIterator copy(ColumnVector[] vectors)

mapping

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