Module delete

Delete records from a Delta Table that statisfy a predicate

When a predicate is not provided then all records are deleted from the Delta Table. Otherwise a scan of the Delta table is performed to mark any files that contain records that satisfy the predicate. Once files are determined they are rewritten without the records.

Predicates MUST be deterministic otherwise undefined behaviour may occur during the scanning and rewriting phase.

Example

let table = open_table("../path/to/table")?;
let (table, metrics) = DeleteBuilder::new(table.object_store(), table.state)
    .with_predicate(col("col1").eq(lit(1)))
    .await?;

Structs

• DeleteBuilder
  Delete Records from the Delta Table. See this module’s documentation for more information
• DeleteMetrics
  Metrics for the Delete Operation