Interface RepairTable

All Superinterfaces:
Action<RepairTable,RepairTable.Result>, SnapshotUpdate<RepairTable,RepairTable.Result>

public interface RepairTable extends SnapshotUpdate<RepairTable,RepairTable.Result>
An action that repairs a table.

The repairs to perform are selected through the configuration methods of this action. Implementations rewrite the affected metadata, producing a new set of manifests in which the repaired entries replace the corrupt ones.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static interface 
    The action result that contains a summary of the execution.
  • Method Summary

    Modifier and Type
    Method
    Description
    Determines the repairs that would be performed without actually committing the operation to the table.
    Repairs incorrect metrics of manifest entries, such as record counts, file sizes and column level statistics, by comparing them against the underlying data and delete files.

    Methods inherited from interface org.apache.iceberg.actions.Action

    execute, option, options

    Methods inherited from interface org.apache.iceberg.actions.SnapshotUpdate

    snapshotProperty
  • Method Details

    • repairFileMetrics

      RepairTable repairFileMetrics()
      Repairs incorrect metrics of manifest entries, such as record counts, file sizes and column level statistics, by comparing them against the underlying data and delete files.
      Returns:
      this for method chaining
    • dryRun

      RepairTable dryRun()
      Determines the repairs that would be performed without actually committing the operation to the table.
      Returns:
      this for method chaining