Package org.apache.iceberg

Class PartitionStatsHandler

java.lang.Object

org.apache.iceberg.PartitionStatsHandler

public class PartitionStatsHandler
extends Object

Computes, writes and reads the PartitionStatisticsFile. Uses generic readers and writers to support writing and reading of the stats in table default format.

Method Summary

Modifier and Type	Method	Description
static PartitionStatisticsFile	computeAndWriteStatsFile(Table table)	Computes the stats incrementally after the snapshot that has partition stats file till the current snapshot and writes the combined result into a PartitionStatisticsFile after merging the stats for a given table's current snapshot.
static PartitionStatisticsFile	computeAndWriteStatsFile(Table table, long snapshotId)	Computes the stats incrementally after the snapshot that has partition stats file till the given snapshot and writes the combined result into a PartitionStatisticsFile after merging the stats for a given snapshot.

Methods inherited from class java.lang.Object

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

Method Details

computeAndWriteStatsFile

public static PartitionStatisticsFile computeAndWriteStatsFile(Table table)
                                                        throws IOException

Computes the stats incrementally after the snapshot that has partition stats file till the current snapshot and writes the combined result into a PartitionStatisticsFile after merging the stats for a given table's current snapshot.

Does a full compute if previous statistics file does not exist.

Parameters:

table - The Table for which the partition statistics is computed.

Returns:

PartitionStatisticsFile for the current snapshot, or null if no statistics are present.

Throws:

IOException

computeAndWriteStatsFile

public static PartitionStatisticsFile computeAndWriteStatsFile(Table table,
 long snapshotId)
                                                        throws IOException

Computes the stats incrementally after the snapshot that has partition stats file till the given snapshot and writes the combined result into a PartitionStatisticsFile after merging the stats for a given snapshot.

Does a full compute if previous statistics file does not exist.

Parameters:

table - The Table for which the partition statistics is computed.

snapshotId - snapshot for which partition statistics are computed.

Returns:

PartitionStatisticsFile for the given snapshot, or null if no statistics are present.

Throws:

IOException