| ParquetBulkWriter<T> |
A simple BulkWriter implementation that wraps a ParquetWriter.
|
| ParquetColumnarRowInputFormat<SplitT extends org.apache.flink.connector.file.src.FileSourceSplit> |
|
| ParquetFileFormatFactory |
Parquet format factory for file system.
|
| ParquetFileFormatFactory.ParquetBulkDecodingFormat |
ParquetBulkDecodingFormat which implements FileBasedStatisticsReportableInputFormat.
|
| ParquetInputFile |
|
| 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.
|