Package org.apache.iceberg.data

Class PartitionStatsHandler

java.lang.Object
org.apache.iceberg.data.PartitionStatsHandler
@Deprecated public class PartitionStatsHandler extends Object
Deprecated.
since 1.10.0, will be removed in 1.11.0; use PartitionStatsHandler from core module
Computes, writes and reads the PartitionStatisticsFile. Uses generic readers and writers to support writing and reading of the stats in table default format.

  • Field Details

    • PARTITION_FIELD_ID

      public static final int PARTITION_FIELD_ID
      Deprecated.
      See Also:

    • PARTITION_FIELD_NAME

      public static final String PARTITION_FIELD_NAME
      Deprecated.
      See Also:

    • SPEC_ID

      public static final Types.NestedField SPEC_ID
      Deprecated.

    • DATA_RECORD_COUNT

      public static final Types.NestedField DATA_RECORD_COUNT
      Deprecated.

    • DATA_FILE_COUNT

      public static final Types.NestedField DATA_FILE_COUNT
      Deprecated.

    • TOTAL_DATA_FILE_SIZE_IN_BYTES

      public static final Types.NestedField TOTAL_DATA_FILE_SIZE_IN_BYTES
      Deprecated.

    • POSITION_DELETE_RECORD_COUNT

      public static final Types.NestedField POSITION_DELETE_RECORD_COUNT
      Deprecated.

    • POSITION_DELETE_FILE_COUNT

      public static final Types.NestedField POSITION_DELETE_FILE_COUNT
      Deprecated.

    • EQUALITY_DELETE_RECORD_COUNT

      public static final Types.NestedField EQUALITY_DELETE_RECORD_COUNT
      Deprecated.

    • EQUALITY_DELETE_FILE_COUNT

      public static final Types.NestedField EQUALITY_DELETE_FILE_COUNT
      Deprecated.

    • TOTAL_RECORD_COUNT

      public static final Types.NestedField TOTAL_RECORD_COUNT
      Deprecated.

    • LAST_UPDATED_AT

      public static final Types.NestedField LAST_UPDATED_AT
      Deprecated.

    • LAST_UPDATED_SNAPSHOT_ID

      public static final Types.NestedField LAST_UPDATED_SNAPSHOT_ID
      Deprecated.

  • Method Details

    • schema

      public static Schema schema(Types.StructType unifiedPartitionType)
      Deprecated.
      Generates the partition stats file schema based on a combined partition type which considers all specs in a table.
      Parameters:
      unifiedPartitionType - unified partition schema type. Could be calculated by Partitioning.partitionType(Table).
      Returns:
      a schema that corresponds to the provided unified partition type.

    • computeAndWriteStatsFile

      public static PartitionStatisticsFile computeAndWriteStatsFile(Table table) throws IOException
      Deprecated.
      Computes and writes the PartitionStatisticsFile for a given table's current snapshot.
      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
      Deprecated.
      Computes and writes the PartitionStatisticsFile for a given table and snapshot.
      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

    • readPartitionStatsFile

      public static CloseableIterable<PartitionStats> readPartitionStatsFile(Schema schema, InputFile inputFile)
      Deprecated.
      Reads partition statistics from the specified InputFile using given schema.
      Parameters:
      schema - The Schema of the partition statistics file.
      inputFile - An InputFile pointing to the partition stats file.