Package org.apache.iceberg

Class PartitionStats

java.lang.Object
org.apache.iceberg.PartitionStats
All Implemented Interfaces:
StructLike
public class PartitionStats extends Object implements StructLike

  • Constructor Details

    • PartitionStats

      public PartitionStats(StructLike partition, int specId)

  • Method Details

    • partition

      public StructLike partition()

    • specId

      public int specId()

    • dataRecordCount

      public long dataRecordCount()

    • dataFileCount

      public int dataFileCount()

    • totalDataFileSizeInBytes

      public long totalDataFileSizeInBytes()

    • positionDeleteRecordCount

      public long positionDeleteRecordCount()

    • positionDeleteFileCount

      public int positionDeleteFileCount()

    • equalityDeleteRecordCount

      public long equalityDeleteRecordCount()

    • equalityDeleteFileCount

      public int equalityDeleteFileCount()

    • totalRecordCount

      @Deprecated public long totalRecordCount()
      Deprecated.
      since 1.9.0, will be removed in 1.10.0, use totalRecords() instead.

    • totalRecords

      public Long totalRecords()

    • lastUpdatedAt

      public Long lastUpdatedAt()

    • lastUpdatedSnapshotId

      public Long lastUpdatedSnapshotId()

    • liveEntry

      public void liveEntry(ContentFile<?> file, Snapshot snapshot)
      Updates the partition stats from the data/delete file.
      Parameters:
      file - the ContentFile from the manifest entry.
      snapshot - the snapshot corresponding to the live entry.

    • deletedEntry

      public void deletedEntry(Snapshot snapshot)
      Updates the modified time and snapshot ID for the deleted manifest entry.
      Parameters:
      snapshot - the snapshot corresponding to the deleted manifest entry.

    • appendStats

      public void appendStats(PartitionStats entry)
      Appends statistics from given entry to current entry.
      Parameters:
      entry - the entry from which statistics will be sourced.

    • size

      public int size()
      Specified by:
      size in interface StructLike

    • get

      public <T> T get(int pos, Class<T> javaClass)
      Specified by:
      get in interface StructLike

    • set

      public <T> void set(int pos, T value)
      Specified by:
      set in interface StructLike