org.apache.paimon.format.parquet.reader

Class NestedPrimitiveColumnReader

java.lang.Object

org.apache.paimon.format.parquet.reader.NestedPrimitiveColumnReader

All Implemented Interfaces:

ColumnReader<WritableColumnVector>

public class NestedPrimitiveColumnReader
extends Object
implements ColumnReader<WritableColumnVector>

Reader to read nested primitive column.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	NestedPrimitiveColumnReader.NullIntIterator Reading zero always.
protected static class	NestedPrimitiveColumnReader.RLEIntIterator Reading int from RunLengthBitPackingHybridDecoder.
protected static class	NestedPrimitiveColumnReader.ValuesReaderIntIterator Reading int from ValuesReader.

Field Summary

Fields

Modifier and Type	Field and Description
protected ParquetReadState	readState Helper struct to track intermediate states while reading Parquet pages in the column chunk.

Constructor Summary

Constructors

Constructor and Description
NestedPrimitiveColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor, org.apache.parquet.column.page.PageReadStore pageReadStore, boolean isUtcTimestamp, org.apache.parquet.schema.Type parquetType, DataType dataType)

Method Summary

Modifier and Type	Method and Description
LevelDelegation	getLevelDelegation()
WritableColumnVector	readAndNewVector(int readNumber, WritableColumnVector vector)
protected int	readPage()
void	readToVector(int readNumber, WritableColumnVector vector)

Methods inherited from class java.lang.Object

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

Field Detail

readState

protected final ParquetReadState readState

Helper struct to track intermediate states while reading Parquet pages in the column chunk.

Constructor Detail

NestedPrimitiveColumnReader

public NestedPrimitiveColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor,
                                   org.apache.parquet.column.page.PageReadStore pageReadStore,
                                   boolean isUtcTimestamp,
                                   org.apache.parquet.schema.Type parquetType,
                                   DataType dataType)
                            throws IOException

Throws:

IOException

Method Detail

readToVector

public void readToVector(int readNumber,
                         WritableColumnVector vector)
                  throws IOException

Specified by:

readToVector in interface ColumnReader<WritableColumnVector>

Parameters:

readNumber - number to read.

vector - vector to write.

Throws:

IOException

readAndNewVector

public WritableColumnVector readAndNewVector(int readNumber,
                                             WritableColumnVector vector)
                                      throws IOException

Throws:

IOException

getLevelDelegation

public LevelDelegation getLevelDelegation()

readPage

protected int readPage()