Package org.apache.iceberg
Class SetPartitionStatistics
- java.lang.Object
-
- org.apache.iceberg.SetPartitionStatistics
-
- All Implemented Interfaces:
PendingUpdate<java.util.List<PartitionStatisticsFile>>
,UpdatePartitionStatistics
public class SetPartitionStatistics extends java.lang.Object implements UpdatePartitionStatistics
-
-
Constructor Summary
Constructors Constructor Description SetPartitionStatistics(TableOperations ops)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.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 Detail
-
SetPartitionStatistics
public SetPartitionStatistics(TableOperations ops)
-
-
Method Detail
-
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.- Specified by:
setPartitionStatistics
in interfaceUpdatePartitionStatistics
- 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 interfaceUpdatePartitionStatistics
- Returns:
- this for method chaining
-
apply
public java.util.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 interfacePendingUpdate<java.util.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 interfacePendingUpdate<java.util.List<PartitionStatisticsFile>>
-
-