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

Interface Summary

Interface	Description
ColumnReader<VECTOR extends org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>	Read a batch of records for a column to WritableColumnVector from parquet data file.
ParquetDataColumnReader	The interface to wrap the underlying Parquet dictionary and non dictionary encoded page reader.

Class Summary

Class	Description
AbstractColumnReader<VECTOR extends org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>	Abstract ColumnReader.
BooleanColumnReader	Boolean ColumnReader.
ByteColumnReader	Byte ColumnReader.
BytesColumnReader	Bytes ColumnReader.
DoubleColumnReader	Double ColumnReader.
FixedLenBytesColumnReader<VECTOR extends org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>	Fixed length bytes ColumnReader, just for decimal.
FloatColumnReader	Float ColumnReader.
IntColumnReader	Int ColumnReader.
LongColumnReader	Long ColumnReader.
NestedColumnReader	This ColumnReader mainly used to read `Group` type in parquet such as `Map`, `Array`, `Row`.
NestedPrimitiveColumnReader	Reader to read nested primitive column.
NestedPrimitiveColumnReader.NullIntIterator	Reading zero always.
NestedPrimitiveColumnReader.RLEIntIterator	Reading int from RunLengthBitPackingHybridDecoder.
NestedPrimitiveColumnReader.ValuesReaderIntIterator	Reading int from ValuesReader.
ParquetDataColumnReaderFactory	Parquet file has self-describing schema which may differ from the user required schema (e.g.
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.
ParquetDataColumnReaderFactory.TypesFromInt96PageReader	The reader who reads from the underlying Timestamp value.
ShortColumnReader	Short ColumnReader.
TimestampColumnReader	Timestamp ColumnReader.