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