All Classes

Class	Description
AbstractColumnReader<VECTOR extends org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector>	Abstract 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.
BooleanColumnReader	Boolean ColumnReader.
ByteColumnReader	Byte ColumnReader.
BytesColumnReader	Bytes ColumnReader.
CollectionPosition	To represent collection's position in repeated type.
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.
LevelDelegation	To delegate repetition level and definition level.
LongColumnReader	Long ColumnReader.
NestedColumnReader	This ColumnReader mainly used to read `Group` type in parquet such as `Map`, `Array`, `Row`.
NestedPositionUtil	Utils to calculate nested type position.
NestedPrimitiveColumnReader	Reader to read nested primitive column.
NestedPrimitiveColumnReader.NullIntIterator	Reading zero always.
NestedPrimitiveColumnReader.RLEIntIterator	Reading int from RunLengthBitPackingHybridDecoder.
NestedPrimitiveColumnReader.ValuesReaderIntIterator	Reading int from ValuesReader.
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.
ParquetField	Field that represent parquet's field type.
ParquetFileFormatFactory	Parquet format factory for file system.
ParquetFileFormatFactory.ParquetBulkDecodingFormat	ParquetBulkDecodingFormat which implements FileBasedStatisticsReportableInputFormat.
ParquetFormatStatisticsReportUtil	Utils for Parquet format statistics report.
ParquetGroupField	Field that represent parquet's Group Field.
ParquetInputFile	Parquet InputFile implementation, ParquetInputFile.newStream() call will delegate to Flink FSDataInputStream.
ParquetPrimitiveField	Field that represent parquet's primitive field.
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.
RowPosition	To represent struct's position in repeated type.
SerializableConfiguration	Wrap Configuration to a serializable class.
ShortColumnReader	Short ColumnReader.
TimestampColumnReader	Timestamp ColumnReader.