Skip to main content

delete_where

Function delete_where 

Source
pub async fn delete_where(
    catalog: Arc<dyn CatalogProvider>,
    store: Arc<dyn Store>,
    table: &TableIdent,
    column_name: &str,
    values: &[&str],
) -> AilakeResult<()>
Expand description

Logically delete all rows where column_name equals any value in values.

Writes an Iceberg equality delete Avro file containing one row per value, then commits a Delete snapshot that inherits existing data manifests and appends a new delete manifest (content=1) pointing to that file.

Scanners that load equality delete files (AI-Lake, Spark, Trino with plugin) will automatically mask matching rows at read time without rewriting data files.

ยงArguments

  • column_name โ€” column to match against (must exist in the table schema)
  • values โ€” values that identify rows to delete