Index (Flink : Formats : Parquet 1.19.2-cp3 API)

A B C D E F G H I J L M N O P R S T U V W
All Classes All Packages

A

AbstractColumnReader<VECTOR extends org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector> - Class in org.apache.flink.formats.parquet.vector.reader: Abstract ColumnReader.
AbstractColumnReader(ColumnDescriptor, PageReader) - Constructor for class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader
addElement(T) - Method in class org.apache.flink.formats.parquet.ParquetBulkWriter
afterReadPage() - Method in class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader: After read a page, we may need some initialization.
afterReadPage() - Method in class org.apache.flink.formats.parquet.vector.reader.BooleanColumnReader
ArrayColumnReader - Class in org.apache.flink.formats.parquet.vector.reader: Array ColumnReader.
ArrayColumnReader(ColumnDescriptor, PageReader, boolean, Type, LogicalType) - Constructor for class org.apache.flink.formats.parquet.vector.reader.ArrayColumnReader
AvroParquetReaders - Class in org.apache.flink.formats.parquet.avro: A convenience builder to create AvroParquetRecordFormat instances for the different kinds of Avro record types.
AvroParquetWriters - Class in org.apache.flink.formats.parquet.avro: Convenience builder to create ParquetWriterFactory instances for the different Avro types.

B

BaseVectorizedColumnReader - Class in org.apache.flink.formats.parquet.vector.reader: 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(ColumnDescriptor, PageReader, boolean, Type, LogicalType) - Constructor for class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader
BaseVectorizedColumnReader.NullIntIterator - Class in org.apache.flink.formats.parquet.vector.reader: Reading zero always.
BaseVectorizedColumnReader.RLEIntIterator - Class in org.apache.flink.formats.parquet.vector.reader: Reading int from RunLengthBitPackingHybridDecoder.
BaseVectorizedColumnReader.ValuesReaderIntIterator - Class in org.apache.flink.formats.parquet.vector.reader: Reading int from ValuesReader.
BooleanColumnReader - Class in org.apache.flink.formats.parquet.vector.reader: Boolean ColumnReader.
BooleanColumnReader(ColumnDescriptor, PageReader) - Constructor for class org.apache.flink.formats.parquet.vector.reader.BooleanColumnReader
ByteColumnReader - Class in org.apache.flink.formats.parquet.vector.reader: Byte ColumnReader.
ByteColumnReader(ColumnDescriptor, PageReader) - Constructor for class org.apache.flink.formats.parquet.vector.reader.ByteColumnReader
BytesColumnReader - Class in org.apache.flink.formats.parquet.vector.reader: Bytes ColumnReader.
BytesColumnReader(ColumnDescriptor, PageReader) - Constructor for class org.apache.flink.formats.parquet.vector.reader.BytesColumnReader

C

checkTypeName(PrimitiveType.PrimitiveTypeName) - Method in class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader
close() - Method in class org.apache.flink.formats.parquet.vector.ParquetColumnarRowSplitReader
columnarBatch - Variable in class org.apache.flink.formats.parquet.ParquetVectorizedInputFormat.ParquetReaderBatch
ColumnBatchFactory<SplitT extends org.apache.flink.connector.file.src.FileSourceSplit> - Interface in org.apache.flink.formats.parquet.vector: Interface to create VectorizedColumnBatch.
ColumnReader<VECTOR extends org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector> - Interface in org.apache.flink.formats.parquet.vector.reader: Read a batch of records for a column to WritableColumnVector from parquet data file.
computeMinBytesForDecimalPrecision(int) - Static method in class org.apache.flink.formats.parquet.utils.ParquetSchemaConverter
conf() - Method in class org.apache.flink.formats.parquet.utils.SerializableConfiguration
convertAndGetIterator(long) - Method in class org.apache.flink.formats.parquet.ParquetVectorizedInputFormat.ParquetReaderBatch: Provides reading iterator after the records are written to the ParquetVectorizedInputFormat.ParquetReaderBatch.columnarBatch.
convertToParquetMessageType(String, RowType, Configuration) - Static method in class org.apache.flink.formats.parquet.utils.ParquetSchemaConverter
convertToParquetType(String, LogicalType, Configuration) - Static method in class org.apache.flink.formats.parquet.utils.ParquetSchemaConverter
create(FSDataOutputStream) - Method in class org.apache.flink.formats.parquet.ParquetWriterFactory
create(SplitT, ColumnVector[]) - Method in interface org.apache.flink.formats.parquet.vector.ColumnBatchFactory
createColumnReader(boolean, LogicalType, Type, List<ColumnDescriptor>, PageReadStore, int) - Static method in class org.apache.flink.formats.parquet.vector.ParquetSplitReaderUtil
createDecodingFormat(DynamicTableFactory.Context, ReadableConfig) - Method in class org.apache.flink.formats.parquet.ParquetFileFormatFactory
createEncodingFormat(DynamicTableFactory.Context, ReadableConfig) - Method in class org.apache.flink.formats.parquet.ParquetFileFormatFactory
createPartitionedFormat(Configuration, RowType, TypeInformation<RowData>, List<String>, PartitionFieldExtractor<SplitT>, int, boolean, boolean) - Static method in class org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat: Create a partitioned ParquetColumnarRowInputFormat, the partition columns can be generated by Path.
createReader(Configuration, SplitT) - Method in class org.apache.flink.formats.parquet.ParquetVectorizedInputFormat
createReaderBatch(WritableColumnVector[], VectorizedColumnBatch, Pool.Recycler<ParquetVectorizedInputFormat.ParquetReaderBatch<RowData>>) - Method in class org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat
createReaderBatch(WritableColumnVector[], VectorizedColumnBatch, Pool.Recycler<ParquetVectorizedInputFormat.ParquetReaderBatch<T>>) - Method in class org.apache.flink.formats.parquet.ParquetVectorizedInputFormat
createRuntimeDecoder(DynamicTableSource.Context, DataType, int[][]) - Method in class org.apache.flink.formats.parquet.ParquetFileFormatFactory.ParquetBulkDecodingFormat
createVectorFromConstant(LogicalType, Object, int) - Static method in class org.apache.flink.formats.parquet.vector.ParquetSplitReaderUtil
createWritableColumnVector(int, LogicalType, Type, List<ColumnDescriptor>, int) - Static method in class org.apache.flink.formats.parquet.vector.ParquetSplitReaderUtil
createWriter(OutputFile) - Method in interface org.apache.flink.formats.parquet.ParquetBuilder: Creates and configures a parquet writer to the given output file.
createWriter(OutputFile) - Method in class org.apache.flink.formats.parquet.row.ParquetRowDataBuilder.FlinkParquetBuilder
createWriterFactory(RowType, Configuration, boolean) - Static method in class org.apache.flink.formats.parquet.row.ParquetRowDataBuilder: Create a parquet BulkWriter.Factory.

D

dataColumn - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader
decodeInt64ToTimestamp(boolean, Dictionary, int, LogicalTypeAnnotation.TimeUnit) - Static method in class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader
decodeInt96ToTimestamp(boolean, Dictionary, int) - Static method in class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader
decodeToBinary(int) - Method in class org.apache.flink.formats.parquet.vector.ParquetDictionary
decodeToDouble(int) - Method in class org.apache.flink.formats.parquet.vector.ParquetDictionary
decodeToFloat(int) - Method in class org.apache.flink.formats.parquet.vector.ParquetDictionary
decodeToInt(int) - Method in class org.apache.flink.formats.parquet.vector.ParquetDictionary
decodeToLong(int) - Method in class org.apache.flink.formats.parquet.vector.ParquetDictionary
decodeToTimestamp(int) - Method in class org.apache.flink.formats.parquet.vector.ParquetDictionary
DefaultParquetDataColumnReader(Dictionary) - Constructor for class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
DefaultParquetDataColumnReader(ValuesReader) - Constructor for class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
definitionLevel - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader
definitionLevelColumn - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader
descriptor - Variable in class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader
descriptor - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader
dict - Variable in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
dictionary - Variable in class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader: The dictionary, if this column has dictionary encoding.
dictionary - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader: The dictionary, if this column has dictionary encoding.
DoubleColumnReader - Class in org.apache.flink.formats.parquet.vector.reader: Double ColumnReader.
DoubleColumnReader(ColumnDescriptor, PageReader) - Constructor for class org.apache.flink.formats.parquet.vector.reader.DoubleColumnReader

E

endOfPageValueCount - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader: value that indicates the end of the current page.

F

factoryIdentifier() - Method in class org.apache.flink.formats.parquet.ParquetFileFormatFactory
finish() - Method in class org.apache.flink.formats.parquet.ParquetBulkWriter
FixedLenBytesColumnReader<VECTOR extends org.apache.flink.table.data.columnar.vector.writable.WritableColumnVector> - Class in org.apache.flink.formats.parquet.vector.reader: Fixed length bytes ColumnReader, just for decimal.
FixedLenBytesColumnReader(ColumnDescriptor, PageReader, int) - Constructor for class org.apache.flink.formats.parquet.vector.reader.FixedLenBytesColumnReader
FlinkParquetBuilder(RowType, Configuration, boolean) - Constructor for class org.apache.flink.formats.parquet.row.ParquetRowDataBuilder.FlinkParquetBuilder
FloatColumnReader - Class in org.apache.flink.formats.parquet.vector.reader: Float ColumnReader.
FloatColumnReader(ColumnDescriptor, PageReader) - Constructor for class org.apache.flink.formats.parquet.vector.reader.FloatColumnReader
flush() - Method in class org.apache.flink.formats.parquet.ParquetBulkWriter
forGenericRecord(Schema) - Static method in class org.apache.flink.formats.parquet.avro.AvroParquetReaders: Creates a new AvroParquetRecordFormat that reads the parquet file into Avro GenericRecords.
forGenericRecord(Schema) - Static method in class org.apache.flink.formats.parquet.avro.AvroParquetWriters: Creates a ParquetWriterFactory that accepts and writes Avro generic types.
forGenericRecord(Schema) - Static method in class org.apache.flink.formats.parquet.avro.ParquetAvroWriters: Deprecated.

Creates a ParquetWriterFactory that accepts and writes Avro generic types.
forReflectRecord(Class<T>) - Static method in class org.apache.flink.formats.parquet.avro.AvroParquetReaders: Creates a new AvroParquetRecordFormat that reads the parquet file into Avro records via reflection.
forReflectRecord(Class<T>) - Static method in class org.apache.flink.formats.parquet.avro.AvroParquetWriters: Creates a ParquetWriterFactory for the given type.
forReflectRecord(Class<T>) - Static method in class org.apache.flink.formats.parquet.avro.ParquetAvroWriters: Deprecated.

Creates a ParquetWriterFactory for the given type.
forSpecificRecord(Class<T>) - Static method in class org.apache.flink.formats.parquet.avro.AvroParquetReaders: Creates a new AvroParquetRecordFormat that reads the parquet file into Avro SpecificRecords.
forSpecificRecord(Class<T>) - Static method in class org.apache.flink.formats.parquet.avro.AvroParquetWriters: Creates a ParquetWriterFactory for an Avro specific type.
forSpecificRecord(Class<T>) - Static method in class org.apache.flink.formats.parquet.avro.ParquetAvroWriters: Deprecated.

Creates a ParquetWriterFactory for an Avro specific type.
forType(Class<T>) - Static method in class org.apache.flink.formats.parquet.protobuf.ParquetProtoWriters: Creates a ParquetWriterFactory for the given type.

G

generate(ColumnVector[]) - Method in interface org.apache.flink.formats.parquet.vector.ParquetColumnarRowSplitReader.ColumnBatchGenerator
genPartColumnarRowReader(boolean, boolean, Configuration, String[], DataType[], Map<String, Object>, int[], int, Path, long, long) - Static method in class org.apache.flink.formats.parquet.vector.ParquetSplitReaderUtil: Util for generating partitioned ParquetColumnarRowSplitReader.
getChangelogMode() - Method in class org.apache.flink.formats.parquet.ParquetFileFormatFactory.ParquetBulkDecodingFormat
getDataColumnReaderByType(PrimitiveType, ValuesReader, boolean) - Static method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory
getDataColumnReaderByTypeOnDictionary(PrimitiveType, Dictionary, boolean) - Static method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory
getDecimal(int, int, int) - Method in class org.apache.flink.formats.parquet.vector.ParquetDecimalVector
getDictionary() - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
getDictionary() - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
getLength() - Method in class org.apache.flink.formats.parquet.ParquetInputFile
getProducedType() - Method in class org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat
getTableStatistics(List<Path>, DataType, Configuration, boolean) - Static method in class org.apache.flink.formats.parquet.utils.ParquetFormatStatisticsReportUtil
getTableStatistics(List<Path>, DataType, Configuration, boolean, int) - Static method in class org.apache.flink.formats.parquet.utils.ParquetFormatStatisticsReportUtil
getVector() - Method in class org.apache.flink.formats.parquet.vector.ParquetDecimalVector
getWriteSupport(Configuration) - Method in class org.apache.flink.formats.parquet.protobuf.ParquetProtoWriters.ParquetProtoWriterBuilder
getWriteSupport(Configuration) - Method in class org.apache.flink.formats.parquet.row.ParquetRowDataBuilder

H

hadoopConfig - Variable in class org.apache.flink.formats.parquet.ParquetVectorizedInputFormat

I

IDENTIFIER - Static variable in class org.apache.flink.formats.parquet.ParquetFileFormatFactory
initFromPage(int, ByteBufferInputStream) - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader: Initialize the reader by page data.
initFromPage(int, ByteBufferInputStream) - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
int64ToTimestamp(boolean, long, LogicalTypeAnnotation.TimeUnit) - Static method in class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader
int96ToTimestamp(boolean, long, int) - Static method in class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader
IntColumnReader - Class in org.apache.flink.formats.parquet.vector.reader: Int ColumnReader.
IntColumnReader(ColumnDescriptor, PageReader) - Constructor for class org.apache.flink.formats.parquet.vector.reader.IntColumnReader
is32BitDecimal(int) - Static method in class org.apache.flink.formats.parquet.utils.ParquetSchemaConverter
is64BitDecimal(int) - Static method in class org.apache.flink.formats.parquet.utils.ParquetSchemaConverter
isCurrentPageDictionaryEncoded - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader: If true, the current page is dictionary encoded.
isNullAt(int) - Method in class org.apache.flink.formats.parquet.vector.ParquetDecimalVector
isSplittable() - Method in class org.apache.flink.formats.parquet.ParquetVectorizedInputFormat
isUtcTimestamp - Variable in class org.apache.flink.formats.parquet.ParquetVectorizedInputFormat
isUtcTimestamp - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader

J

JULIAN_EPOCH_OFFSET_DAYS - Static variable in class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader

L

logicalType - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader
LongColumnReader - Class in org.apache.flink.formats.parquet.vector.reader: Long ColumnReader.
LongColumnReader(ColumnDescriptor, PageReader) - Constructor for class org.apache.flink.formats.parquet.vector.reader.LongColumnReader

M

MapColumnReader - Class in org.apache.flink.formats.parquet.vector.reader: Map ColumnReader.
MapColumnReader(ArrayColumnReader, ArrayColumnReader) - Constructor for class org.apache.flink.formats.parquet.vector.reader.MapColumnReader
maxDefLevel - Variable in class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader: Maximum definition level for this column.
maxDefLevel - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader: Maximum definition level for this column.
MICROS_PER_MILLISECOND - Static variable in class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader
MICROS_PER_SECOND - Static variable in class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader
MILLIS_IN_DAY - Static variable in class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader
MILLIS_PER_SECOND - Static variable in class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader

N

NANOS_PER_MICROSECONDS - Static variable in class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader
NANOS_PER_MILLISECOND - Static variable in class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader
NANOS_PER_SECOND - Static variable in class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader
newStream() - Method in class org.apache.flink.formats.parquet.ParquetInputFile
nextInt() - Method in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader.NullIntIterator
nextInt() - Method in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader.RLEIntIterator
nextInt() - Method in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader.ValuesReaderIntIterator
nextRecord() - Method in class org.apache.flink.formats.parquet.vector.ParquetColumnarRowSplitReader
NullIntIterator() - Constructor for class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader.NullIntIterator
numBatchesToCirculate(Configuration) - Method in class org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat
numBatchesToCirculate(Configuration) - Method in class org.apache.flink.formats.parquet.ParquetVectorizedInputFormat

O

optionalOptions() - Method in class org.apache.flink.formats.parquet.ParquetFileFormatFactory
org.apache.flink.formats.parquet - package org.apache.flink.formats.parquet
org.apache.flink.formats.parquet.avro - package org.apache.flink.formats.parquet.avro
org.apache.flink.formats.parquet.protobuf - package org.apache.flink.formats.parquet.protobuf
org.apache.flink.formats.parquet.row - package org.apache.flink.formats.parquet.row
org.apache.flink.formats.parquet.utils - package org.apache.flink.formats.parquet.utils
org.apache.flink.formats.parquet.vector - package org.apache.flink.formats.parquet.vector
org.apache.flink.formats.parquet.vector.reader - package org.apache.flink.formats.parquet.vector.reader

P

pageReader - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader
pageValueCount - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader: Total values in the current page.
ParquetAvroWriters - Class in org.apache.flink.formats.parquet.avro: Deprecated.
use AvroParquetWriters instead.
ParquetBuilder<T> - Interface in org.apache.flink.formats.parquet: A builder to create a ParquetWriter from a Parquet OutputFile.
ParquetBulkDecodingFormat(ReadableConfig) - Constructor for class org.apache.flink.formats.parquet.ParquetFileFormatFactory.ParquetBulkDecodingFormat
ParquetBulkWriter<T> - Class in org.apache.flink.formats.parquet: A simple BulkWriter implementation that wraps a ParquetWriter.
ParquetBulkWriter(ParquetWriter<T>) - Constructor for class org.apache.flink.formats.parquet.ParquetBulkWriter: Creates a new ParquetBulkWriter wrapping the given ParquetWriter.
ParquetColumnarRowInputFormat<SplitT extends org.apache.flink.connector.file.src.FileSourceSplit> - Class in org.apache.flink.formats.parquet: A ParquetVectorizedInputFormat to provide RowData iterator.
ParquetColumnarRowInputFormat(Configuration, RowType, TypeInformation<RowData>, int, boolean, boolean) - Constructor for class org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat: Constructor to create parquet format without extra fields.
ParquetColumnarRowSplitReader - Class in org.apache.flink.formats.parquet.vector: This reader is used to read a VectorizedColumnBatch from input split.
ParquetColumnarRowSplitReader(boolean, boolean, Configuration, LogicalType[], String[], ParquetColumnarRowSplitReader.ColumnBatchGenerator, int, Path, long, long) - Constructor for class org.apache.flink.formats.parquet.vector.ParquetColumnarRowSplitReader
ParquetColumnarRowSplitReader.ColumnBatchGenerator - Interface in org.apache.flink.formats.parquet.vector: Interface to gen VectorizedColumnBatch.
ParquetDataColumnReader - Interface in org.apache.flink.formats.parquet.vector.reader: The interface to wrap the underlying Parquet dictionary and non dictionary encoded page reader.
ParquetDataColumnReaderFactory - Class in org.apache.flink.formats.parquet.vector.reader: Parquet file has self-describing schema which may differ from the user required schema (e.g.
ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader - Class in org.apache.flink.formats.parquet.vector.reader: 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 - Class in org.apache.flink.formats.parquet.vector.reader: The reader who reads from the underlying Timestamp value.
ParquetDecimalVector - Class in org.apache.flink.formats.parquet.vector: Parquet write decimal as int32 and int64 and binary, this class wrap the real vector to provide DecimalColumnVector interface.
ParquetDecimalVector(ColumnVector) - Constructor for class org.apache.flink.formats.parquet.vector.ParquetDecimalVector
ParquetDictionary - Class in org.apache.flink.formats.parquet.vector: Parquet dictionary.
ParquetDictionary(Dictionary, ColumnDescriptor) - Constructor for class org.apache.flink.formats.parquet.vector.ParquetDictionary
ParquetFileFormatFactory - Class in org.apache.flink.formats.parquet: Parquet format factory for file system.
ParquetFileFormatFactory() - Constructor for class org.apache.flink.formats.parquet.ParquetFileFormatFactory
ParquetFileFormatFactory.ParquetBulkDecodingFormat - Class in org.apache.flink.formats.parquet: ParquetBulkDecodingFormat which implements FileBasedStatisticsReportableInputFormat.
ParquetFormatStatisticsReportUtil - Class in org.apache.flink.formats.parquet.utils: Utils for Parquet format statistics report.
ParquetFormatStatisticsReportUtil() - Constructor for class org.apache.flink.formats.parquet.utils.ParquetFormatStatisticsReportUtil
ParquetInputFile - Class in org.apache.flink.formats.parquet: Parquet InputFile implementation, ParquetInputFile.newStream() call will delegate to Flink FSDataInputStream.
ParquetInputFile(FSDataInputStream, long) - Constructor for class org.apache.flink.formats.parquet.ParquetInputFile
ParquetProtoWriterBuilder(OutputFile, Class<T>) - Constructor for class org.apache.flink.formats.parquet.protobuf.ParquetProtoWriters.ParquetProtoWriterBuilder
ParquetProtoWriters - Class in org.apache.flink.formats.parquet.protobuf: Convenience builder for creating ParquetWriterFactory instances for Protobuf classes.
ParquetProtoWriters.ParquetProtoWriterBuilder<T extends com.google.protobuf.Message> - Class in org.apache.flink.formats.parquet.protobuf: The builder for Protobuf ParquetWriter.
ParquetReaderBatch(WritableColumnVector[], VectorizedColumnBatch, Pool.Recycler<ParquetVectorizedInputFormat.ParquetReaderBatch<T>>) - Constructor for class org.apache.flink.formats.parquet.ParquetVectorizedInputFormat.ParquetReaderBatch
ParquetRowDataBuilder - Class in org.apache.flink.formats.parquet.row: RowData of ParquetWriter.Builder.
ParquetRowDataBuilder(OutputFile, RowType, boolean) - Constructor for class org.apache.flink.formats.parquet.row.ParquetRowDataBuilder
ParquetRowDataBuilder.FlinkParquetBuilder - Class in org.apache.flink.formats.parquet.row: Flink Row ParquetBuilder.
ParquetRowDataWriter - Class in org.apache.flink.formats.parquet.row: Writes a record to the Parquet API with the expected schema in order to be written to a file.
ParquetRowDataWriter(RecordConsumer, RowType, GroupType, boolean, Configuration) - Constructor for class org.apache.flink.formats.parquet.row.ParquetRowDataWriter
ParquetSchemaConverter - Class in org.apache.flink.formats.parquet.utils: Schema converter converts Parquet schema to and from Flink internal types.
ParquetSchemaConverter() - Constructor for class org.apache.flink.formats.parquet.utils.ParquetSchemaConverter
ParquetSplitReaderUtil - Class in org.apache.flink.formats.parquet.vector: Util for generating ParquetColumnarRowSplitReader.
ParquetSplitReaderUtil() - Constructor for class org.apache.flink.formats.parquet.vector.ParquetSplitReaderUtil
ParquetVectorizedInputFormat<T,SplitT extends org.apache.flink.connector.file.src.FileSourceSplit> - Class in org.apache.flink.formats.parquet: Parquet BulkFormat that reads data from the file to VectorizedColumnBatch in vectorized mode.
ParquetVectorizedInputFormat(SerializableConfiguration, RowType, ColumnBatchFactory<SplitT>, int, boolean, boolean) - Constructor for class org.apache.flink.formats.parquet.ParquetVectorizedInputFormat
ParquetVectorizedInputFormat.ParquetReaderBatch<T> - Class in org.apache.flink.formats.parquet: Reader batch that provides writing and reading capabilities.
ParquetWriterFactory<T> - Class in org.apache.flink.formats.parquet: A factory that creates a Parquet BulkWriter.
ParquetWriterFactory(ParquetBuilder<T>) - Constructor for class org.apache.flink.formats.parquet.ParquetWriterFactory: Creates a new ParquetWriterFactory using the given builder to assemble the ParquetWriter.

R

reachedEnd() - Method in class org.apache.flink.formats.parquet.vector.ParquetColumnarRowSplitReader: Method used to check if the end of the input is reached.
readBatch(int, int, WritableBooleanVector) - Method in class org.apache.flink.formats.parquet.vector.reader.BooleanColumnReader
readBatch(int, int, WritableBytesVector) - Method in class org.apache.flink.formats.parquet.vector.reader.BytesColumnReader
readBatch(int, int, WritableByteVector) - Method in class org.apache.flink.formats.parquet.vector.reader.ByteColumnReader
readBatch(int, int, WritableDoubleVector) - Method in class org.apache.flink.formats.parquet.vector.reader.DoubleColumnReader
readBatch(int, int, WritableFloatVector) - Method in class org.apache.flink.formats.parquet.vector.reader.FloatColumnReader
readBatch(int, int, WritableIntVector) - Method in class org.apache.flink.formats.parquet.vector.reader.IntColumnReader
readBatch(int, int, WritableLongVector) - Method in class org.apache.flink.formats.parquet.vector.reader.LongColumnReader
readBatch(int, int, WritableShortVector) - Method in class org.apache.flink.formats.parquet.vector.reader.ShortColumnReader
readBatch(int, int, WritableTimestampVector) - Method in class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader
readBatch(int, int, VECTOR) - Method in class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader: Read batch from AbstractColumnReader.runLenDecoder and AbstractColumnReader.dataInputStream.
readBatch(int, int, VECTOR) - Method in class org.apache.flink.formats.parquet.vector.reader.FixedLenBytesColumnReader
readBatch(int, ColumnVector) - Method in class org.apache.flink.formats.parquet.vector.reader.MapColumnReader
readBatchFromDictionaryIds(int, int, WritableBooleanVector, WritableIntVector) - Method in class org.apache.flink.formats.parquet.vector.reader.BooleanColumnReader
readBatchFromDictionaryIds(int, int, WritableBytesVector, WritableIntVector) - Method in class org.apache.flink.formats.parquet.vector.reader.BytesColumnReader
readBatchFromDictionaryIds(int, int, WritableByteVector, WritableIntVector) - Method in class org.apache.flink.formats.parquet.vector.reader.ByteColumnReader
readBatchFromDictionaryIds(int, int, WritableDoubleVector, WritableIntVector) - Method in class org.apache.flink.formats.parquet.vector.reader.DoubleColumnReader
readBatchFromDictionaryIds(int, int, WritableFloatVector, WritableIntVector) - Method in class org.apache.flink.formats.parquet.vector.reader.FloatColumnReader
readBatchFromDictionaryIds(int, int, WritableIntVector, WritableIntVector) - Method in class org.apache.flink.formats.parquet.vector.reader.IntColumnReader
readBatchFromDictionaryIds(int, int, WritableLongVector, WritableIntVector) - Method in class org.apache.flink.formats.parquet.vector.reader.LongColumnReader
readBatchFromDictionaryIds(int, int, WritableShortVector, WritableIntVector) - Method in class org.apache.flink.formats.parquet.vector.reader.ShortColumnReader
readBatchFromDictionaryIds(int, int, WritableTimestampVector, WritableIntVector) - Method in class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader
readBatchFromDictionaryIds(int, int, VECTOR, WritableIntVector) - Method in class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader: Decode dictionary ids to data.
readBatchFromDictionaryIds(int, int, VECTOR, WritableIntVector) - Method in class org.apache.flink.formats.parquet.vector.reader.FixedLenBytesColumnReader
readBoolean() - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readBoolean() - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readBoolean(int) - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readBoolean(int) - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readBytes() - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readBytes() - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readBytes(int) - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readBytes(int) - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readDouble() - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readDouble() - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readDouble(int) - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readDouble(int) - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readFloat() - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readFloat() - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readFloat(int) - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readFloat(int) - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readInteger() - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readInteger() - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readInteger(int) - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readInteger(int) - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readLong() - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readLong() - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readLong(int) - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readLong(int) - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readPage() - Method in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader
readRepetitionAndDefinitionLevels() - Method in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader
readSmallInt() - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readSmallInt() - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readSmallInt(int) - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readSmallInt(int) - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readTimestamp() - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readTimestamp() - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readTimestamp() - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.TypesFromInt96PageReader
readTimestamp(int) - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readTimestamp(int) - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readTimestamp(int) - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.TypesFromInt96PageReader
readTinyInt() - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readTinyInt() - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readTinyInt(int) - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readTinyInt(int) - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
readToVector(int, WritableColumnVector) - Method in class org.apache.flink.formats.parquet.vector.reader.ArrayColumnReader
readToVector(int, WritableColumnVector) - Method in class org.apache.flink.formats.parquet.vector.reader.MapColumnReader
readToVector(int, WritableColumnVector) - Method in class org.apache.flink.formats.parquet.vector.reader.RowColumnReader
readToVector(int, VECTOR) - Method in class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader: Reads `total` values from this columnReader into column.
readToVector(int, VECTOR) - Method in interface org.apache.flink.formats.parquet.vector.reader.ColumnReader
readValueDictionaryId() - Method in interface org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReader
readValueDictionaryId() - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
recycle() - Method in class org.apache.flink.formats.parquet.ParquetVectorizedInputFormat.ParquetReaderBatch
repetitionLevel - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader
repetitionLevelColumn - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader: Repetition/Definition/Value readers.
reportStatistics(List<Path>, DataType) - Method in class org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat
reportStatistics(List<Path>, DataType) - Method in class org.apache.flink.formats.parquet.ParquetFileFormatFactory.ParquetBulkDecodingFormat
requiredOptions() - Method in class org.apache.flink.formats.parquet.ParquetFileFormatFactory
restoreReader(Configuration, SplitT) - Method in class org.apache.flink.formats.parquet.ParquetVectorizedInputFormat
RLEIntIterator(RunLengthBitPackingHybridDecoder) - Constructor for class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader.RLEIntIterator
RowColumnReader - Class in org.apache.flink.formats.parquet.vector.reader: Row ColumnReader.
RowColumnReader(List<ColumnReader>) - Constructor for class org.apache.flink.formats.parquet.vector.reader.RowColumnReader
runLenDecoder - Variable in class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader: Run length decoder for data and dictionary.

S

seekToRow(long) - Method in class org.apache.flink.formats.parquet.vector.ParquetColumnarRowSplitReader: Seek to a particular row number.
self() - Method in class org.apache.flink.formats.parquet.protobuf.ParquetProtoWriters.ParquetProtoWriterBuilder
self() - Method in class org.apache.flink.formats.parquet.row.ParquetRowDataBuilder
SerializableConfiguration - Class in org.apache.flink.formats.parquet.utils: Wrap Configuration to a serializable class.
SerializableConfiguration(Configuration) - Constructor for class org.apache.flink.formats.parquet.utils.SerializableConfiguration
ShortColumnReader - Class in org.apache.flink.formats.parquet.vector.reader: Short ColumnReader.
ShortColumnReader(ColumnDescriptor, PageReader) - Constructor for class org.apache.flink.formats.parquet.vector.reader.ShortColumnReader
skip() - Method in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
supportLazyDecode() - Method in class org.apache.flink.formats.parquet.vector.reader.AbstractColumnReader: Support lazy dictionary ids decode.
supportLazyDecode() - Method in class org.apache.flink.formats.parquet.vector.reader.BooleanColumnReader
supportLazyDecode() - Method in class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader

T

TIMESTAMP_TIME_UNIT - Static variable in class org.apache.flink.formats.parquet.ParquetFileFormatFactory
TimestampColumnReader - Class in org.apache.flink.formats.parquet.vector.reader: Timestamp ColumnReader.
TimestampColumnReader(boolean, ColumnDescriptor, PageReader) - Constructor for class org.apache.flink.formats.parquet.vector.reader.TimestampColumnReader
type - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader
TypesFromInt96PageReader(Dictionary, boolean) - Constructor for class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.TypesFromInt96PageReader
TypesFromInt96PageReader(ValuesReader, boolean) - Constructor for class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.TypesFromInt96PageReader

U

UTC_TIMEZONE - Static variable in class org.apache.flink.formats.parquet.ParquetFileFormatFactory

V

valuesRead - Variable in class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader: Total number of values read.
valuesReader - Variable in class org.apache.flink.formats.parquet.vector.reader.ParquetDataColumnReaderFactory.DefaultParquetDataColumnReader
ValuesReaderIntIterator(ValuesReader) - Constructor for class org.apache.flink.formats.parquet.vector.reader.BaseVectorizedColumnReader.ValuesReaderIntIterator

W

withoutExtraFields() - Static method in interface org.apache.flink.formats.parquet.vector.ColumnBatchFactory
write(RowData) - Method in class org.apache.flink.formats.parquet.row.ParquetRowDataWriter: It writes a record to Parquet.
WRITE_INT64_TIMESTAMP - Static variable in class org.apache.flink.formats.parquet.ParquetFileFormatFactory

A B C D E F G H I J L M N O P R S T U V W
All Classes All Packages