org.apache.paimon.format.parquet

Class ParquetReaderFactory

java.lang.Object

org.apache.paimon.format.parquet.ParquetReaderFactory

All Implemented Interfaces:

FormatReaderFactory

public class ParquetReaderFactory
extends Object
implements FormatReaderFactory

Parquet FormatReaderFactory that reads data from the file to VectorizedColumnBatch in vectorized mode.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.format.FormatReaderFactory

FormatReaderFactory.Context

Constructor Summary

Constructors

Constructor and Description
ParquetReaderFactory(Options conf, RowType projectedType, int batchSize, org.apache.parquet.filter2.compat.FilterCompat.Filter filter)

Method Summary

Modifier and Type	Method and Description
FileRecordReader<InternalRow>	createReader(FormatReaderFactory.Context context)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ParquetReaderFactory

public ParquetReaderFactory(Options conf,
                            RowType projectedType,
                            int batchSize,
                            org.apache.parquet.filter2.compat.FilterCompat.Filter filter)

Method Detail

createReader

public FileRecordReader<InternalRow> createReader(FormatReaderFactory.Context context)
                                           throws IOException

Specified by:

createReader in interface FormatReaderFactory

Throws:

IOException