Package org.apache.iceberg

Class SetPartitionStatistics

java.lang.Object

org.apache.iceberg.SetPartitionStatistics

All Implemented Interfaces:

PendingUpdate<List<PartitionStatisticsFile>>, UpdatePartitionStatistics

public class SetPartitionStatistics
extends Object
implements UpdatePartitionStatistics

Constructor Summary

Constructors

Constructor	Description
SetPartitionStatistics(TableOperations ops)

Method Summary

Modifier and Type	Method	Description
List<PartitionStatisticsFile>	apply()	Apply the pending changes and return the uncommitted changes for validation.
void	commit()	Apply the pending changes and commit.
UpdatePartitionStatistics	removePartitionStatistics(long snapshotId)	Remove the table's partition statistics file for given snapshot.
UpdatePartitionStatistics	setPartitionStatistics(PartitionStatisticsFile file)	Set the table's partition statistics file for given snapshot, replacing the previous partition statistics file for the snapshot if any exists.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.PendingUpdate

updateEvent

Constructor Details

SetPartitionStatistics

public SetPartitionStatistics(TableOperations ops)

Method Details

setPartitionStatistics

public UpdatePartitionStatistics setPartitionStatistics(PartitionStatisticsFile file)

Description copied from interface: UpdatePartitionStatistics

Set the table's partition statistics file for given snapshot, replacing the previous partition statistics file for the snapshot if any exists. No-op if the provided file is null.

Specified by:

setPartitionStatistics in interface UpdatePartitionStatistics

Returns:

this for method chaining

removePartitionStatistics

public UpdatePartitionStatistics removePartitionStatistics(long snapshotId)

Description copied from interface: UpdatePartitionStatistics

Remove the table's partition statistics file for given snapshot.

Specified by:

removePartitionStatistics in interface UpdatePartitionStatistics

Returns:

this for method chaining

apply

public List<PartitionStatisticsFile> apply()

Description copied from interface: PendingUpdate

Apply the pending changes and return the uncommitted changes for validation.

This does not result in a permanent update.

Specified by:

apply in interface PendingUpdate<List<PartitionStatisticsFile>>

Returns:

the uncommitted changes that would be committed by calling PendingUpdate.commit()

commit

public void commit()

Description copied from interface: PendingUpdate

Apply the pending changes and commit.

Changes are committed by calling the underlying table's commit method.

Once the commit is successful, the updated table will be refreshed.

Specified by:

commit in interface PendingUpdate<List<PartitionStatisticsFile>>