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

Class ArrayColumnReader

java.lang.Object

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

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

All Implemented Interfaces:

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

public class ArrayColumnReader
extends BaseVectorizedColumnReader

Array ColumnReader. TODO Currently ARRAY type only support non nested case.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader

BaseVectorizedColumnReader.NullIntIterator, BaseVectorizedColumnReader.RLEIntIterator, BaseVectorizedColumnReader.ValuesReaderIntIterator

Field Summary

Fields inherited from class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader

dataColumn, definitionLevel, definitionLevelColumn, descriptor, dictionary, endOfPageValueCount, isCurrentPageDictionaryEncoded, isUtcTimestamp, logicalType, maxDefLevel, pageReader, pageValueCount, repetitionLevel, repetitionLevelColumn, type, valuesRead

Constructor Summary

Constructors

Constructor	Description
ArrayColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor, org.apache.parquet.column.page.PageReader pageReader, boolean isUtcTimestamp, org.apache.parquet.schema.Type type, org.apache.flink.table.types.logical.LogicalType logicalType)

Method Summary

Modifier and Type	Method	Description
void	readToVector(int readNumber, org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector vector)

Methods inherited from class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader

readPage, readRepetitionAndDefinitionLevels

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrayColumnReader

public ArrayColumnReader(org.apache.parquet.column.ColumnDescriptor descriptor,
                         org.apache.parquet.column.page.PageReader pageReader,
                         boolean isUtcTimestamp,
                         org.apache.parquet.schema.Type type,
                         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)

Parameters:

readNumber - number to read.

vector - vector to write.