Package org.apache.iceberg.parquet
Class ParquetCodecFactory
- java.lang.Object
-
- org.apache.parquet.hadoop.CodecFactory
-
- org.apache.iceberg.parquet.ParquetCodecFactory
-
- All Implemented Interfaces:
org.apache.parquet.compression.CompressionCodecFactory
public class ParquetCodecFactory extends org.apache.parquet.hadoop.CodecFactory
This class implements a codec factory that is used when reading from Parquet. It adds a workaround for memory issues encountered when reading from zstd-compressed files.
-
-
Constructor Summary
Constructors Constructor Description ParquetCodecFactory(org.apache.hadoop.conf.Configuration configuration, int pageSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.apache.parquet.hadoop.CodecFactory.BytesDecompressor
createDecompressor(org.apache.parquet.hadoop.metadata.CompressionCodecName codecName)
-