Package org.apache.flink.formats.parquet.vector.reader

Class NestedPrimitiveColumnReader

java.lang.Object

org.apache.flink.formats.parquet.vector.reader.NestedPrimitiveColumnReader

All Implemented Interfaces:

ColumnReader<org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>

public class NestedPrimitiveColumnReader
extends Object
implements ColumnReader<org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>

Reader to read nested primitive column.

Nested Class Summary

Nested Classes

Modifier and Type	Class	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	Description
NestedPrimitiveColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor, org.apache.parquet.column.page.PageReader pageReader, boolean isUtcTimestamp, org.apache.parquet.schema.Type parquetType, org.apache.flink.table.types.logical.LogicalType logicalType)

Method Summary

Modifier and Type	Method	Description
LevelDelegation	getLevelDelegation()
org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector	readAndNewVector(int readNumber, org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector vector)
protected void	readPage()
void	readToVector(int readNumber, org.apache.flink.table.data.columnar.vector.writable.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,
                                   org.apache.flink.table.types.logical.LogicalType logicalType)
                            throws IOException

Throws:

IOException

Method Detail

readToVector

public void readToVector(int readNumber,
                         org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector vector)
                  throws IOException

Specified by:

readToVector in interface ColumnReader<org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>

Parameters:

readNumber - number to read.

vector - vector to write.

Throws:

IOException

readAndNewVector

public org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector readAndNewVector(int readNumber,
                                                                                                  org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector vector)
                                                                                           throws IOException

Throws:

IOException

getLevelDelegation

public LevelDelegation getLevelDelegation()

readPage

protected void readPage()