Package io.delta.kernel.defaults.internal.parquet

Class ParquetStatsReader

Object

io.delta.kernel.defaults.internal.parquet.ParquetStatsReader

public class ParquetStatsReader
extends Object

Helper class to read statistics from Parquet files.

Constructor Summary

Constructors

Constructor	Description
ParquetStatsReader()

Method Summary

Modifier and Type	Method	Description
static io.delta.kernel.statistics.DataFileStatistics	readDataFileStatistics(InputFile kernelInputFile, io.delta.kernel.types.StructType dataSchema, List<io.delta.kernel.expressions.Column> statsColumns)	Read the statistics for the given Parquet file.

Methods inherited from class java.lang.Object

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

Constructor Details

ParquetStatsReader

public ParquetStatsReader()

Method Details

readDataFileStatistics

public static io.delta.kernel.statistics.DataFileStatistics readDataFileStatistics(InputFile kernelInputFile,
 io.delta.kernel.types.StructType dataSchema,
 List<io.delta.kernel.expressions.Column> statsColumns)
                                                                            throws IOException

Read the statistics for the given Parquet file.

Parameters:

kernelInputFile - InputFile representing the Parquet file.

dataSchema - The schema of the Parquet file. Type info is used to decode statistics.

statsColumns - The columns for which statistics should be collected and returned.

Returns:

File/column level statistics as DataFileStatistics instance.

Throws:

IOException