Interface | Description |
---|---|
ParquetBuilder<T> |
A builder to create a
ParquetWriter from a Parquet OutputFile . |
Class | Description |
---|---|
ParquetBulkWriter<T> |
A simple
BulkWriter implementation that wraps a ParquetWriter . |
ParquetColumnarRowInputFormat<SplitT extends FileSourceSplit> |
A
ParquetVectorizedInputFormat to provide RowData iterator. |
ParquetFileFormatFactory |
Parquet format factory for file system.
|
ParquetFileFormatFactory.ParquetBulkDecodingFormat |
ParquetBulkDecodingFormat which implements
FileBasedStatisticsReportableInputFormat . |
ParquetInputFile |
Parquet
InputFile implementation, ParquetInputFile.newStream() call will delegate to Flink FSDataInputStream . |
ParquetVectorizedInputFormat<T,SplitT extends 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 . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.