All Classes

Class	Description
AbstractColumnReader<VECTOR extends org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>	Abstract ColumnReader.
ArrayColumnReader	Array ColumnReader.
AvroParquetReaders	A convenience builder to create AvroParquetRecordFormat instances for the different kinds of Avro record types.
AvroParquetWriters	Convenience builder to create ParquetWriterFactory instances for the different Avro types.
BaseVectorizedColumnReader	It's column level Parquet reader which is used to read a batch of records for a column, part of the code is referred from Apache Hive and Apache Parquet.
BaseVectorizedColumnReader.NullIntIterator	Reading zero always.
BaseVectorizedColumnReader.RLEIntIterator	Reading int from RunLengthBitPackingHybridDecoder.
BaseVectorizedColumnReader.ValuesReaderIntIterator	Reading int from ValuesReader.
BooleanColumnReader	Boolean ColumnReader.
ByteColumnReader	Byte ColumnReader.
BytesColumnReader	Bytes ColumnReader.
ColumnBatchFactory<SplitT extends org.apache.flink.connector.file.src.FileSourceSplit>	Interface to create VectorizedColumnBatch.
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.
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.
MapColumnReader	Map ColumnReader.
ParquetAvroWriters	Deprecated. use AvroParquetWriters instead.
ParquetBuilder<T>	A builder to create a ParquetWriter from a Parquet OutputFile.
ParquetBulkWriter<T>	A simple BulkWriter implementation that wraps a ParquetWriter.
ParquetColumnarRowInputFormat<SplitT extends org.apache.flink.connector.file.src.FileSourceSplit>	A ParquetVectorizedInputFormat to provide RowData iterator.
ParquetColumnarRowSplitReader	This reader is used to read a VectorizedColumnBatch from input split.
ParquetColumnarRowSplitReader.ColumnBatchGenerator	Interface to gen VectorizedColumnBatch.
ParquetDataColumnReader	The interface to wrap the underlying Parquet dictionary and non dictionary encoded page reader.
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.
ParquetDecimalVector	Parquet write decimal as int32 and int64 and binary, this class wrap the real vector to provide DecimalColumnVector interface.
ParquetDictionary	Parquet dictionary.
ParquetFileFormatFactory	Parquet format factory for file system.
ParquetFileFormatFactory.ParquetBulkDecodingFormat	ParquetBulkDecodingFormat which implements FileBasedStatisticsReportableInputFormat.
ParquetFormatStatisticsReportUtil	Utils for Parquet format statistics report.
ParquetInputFile	Parquet InputFile implementation, ParquetInputFile.newStream() call will delegate to Flink FSDataInputStream.
ParquetProtoWriters	Convenience builder for creating ParquetWriterFactory instances for Protobuf classes.
ParquetProtoWriters.ParquetProtoWriterBuilder<T extends com.google.protobuf.Message>	The builder for Protobuf ParquetWriter.
ParquetRowDataBuilder	RowData of ParquetWriter.Builder.
ParquetRowDataBuilder.FlinkParquetBuilder	Flink Row ParquetBuilder.
ParquetRowDataWriter	Writes a record to the Parquet API with the expected schema in order to be written to a file.
ParquetSchemaConverter	Schema converter converts Parquet schema to and from Flink internal types.
ParquetSplitReaderUtil	Util for generating ParquetColumnarRowSplitReader.
ParquetVectorizedInputFormat<T,SplitT extends org.apache.flink.connector.file.src.FileSourceSplit>	Parquet BulkFormat that reads data from the file to VectorizedColumnBatch in vectorized mode.
ParquetVectorizedInputFormat.ParquetReaderBatch<T>	Reader batch that provides writing and reading capabilities.
ParquetWriterFactory<T>	A factory that creates a Parquet BulkWriter.
RowColumnReader	Row ColumnReader.
SerializableConfiguration	Wrap Configuration to a serializable class.
ShortColumnReader	Short ColumnReader.
TimestampColumnReader	Timestamp ColumnReader.