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

Class ParquetDataColumnReaderFactory

java.lang.Object

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

public final class ParquetDataColumnReaderFactory
extends Object

Parquet file has self-describing schema which may differ from the user required schema (e.g. schema evolution). This factory is used to retrieve user required typed data via corresponding reader which reads the underlying data. Part of the code is referred from Apache Hive.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader	The default data column reader for existing Parquet page reader which works for both dictionary or non dictionary types, Mirror from dictionary encoding path.
static class	ParquetDataColumnReaderFactory.TypesFromInt96PageReader	The reader who reads from the underlying Timestamp value.

Method Summary

Modifier and Type	Method	Description
static ParquetDataColumnReader	getDataColumnReaderByType(org.apache.parquet.schema.PrimitiveType parquetType, org.apache.parquet.column.values.ValuesReader realReader, boolean isUtcTimestamp)
static ParquetDataColumnReader	getDataColumnReaderByTypeOnDictionary(org.apache.parquet.schema.PrimitiveType parquetType, org.apache.parquet.column.Dictionary realReader, boolean isUtcTimestamp)

Methods inherited from class java.lang.Object

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

Method Detail

getDataColumnReaderByTypeOnDictionary

public static ParquetDataColumnReader getDataColumnReaderByTypeOnDictionary(org.apache.parquet.schema.PrimitiveType parquetType,
                                                                            org.apache.parquet.column.Dictionary realReader,
                                                                            boolean isUtcTimestamp)

getDataColumnReaderByType

public static ParquetDataColumnReader getDataColumnReaderByType(org.apache.parquet.schema.PrimitiveType parquetType,
                                                                org.apache.parquet.column.values.ValuesReader realReader,
                                                                boolean isUtcTimestamp)