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.

Constructor Summary

Constructors

Constructor and Description
NestedPrimitiveColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor, org.apache.parquet.column.page.PageReader pageReader, boolean isUtcTimestamp, org.apache.parquet.schema.Type parquetType, DataType dataType, boolean readRowField, boolean readMapKey)

Method Summary

Modifier and Type	Method and Description
LevelDelegation	getLevelDelegation()
WritableColumnVector	readAndNewVector(int readNumber, WritableColumnVector vector)
protected void	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

Constructor Detail

NestedPrimitiveColumnReader

public NestedPrimitiveColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor,
                                   org.apache.parquet.column.page.PageReader pageReader,
                                   boolean isUtcTimestamp,
                                   org.apache.parquet.schema.Type parquetType,
                                   DataType dataType,
                                   boolean readRowField,
                                   boolean readMapKey)
                            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 void readPage()