Struct EqualityDeleteFilter 

pub struct EqualityDeleteFilter { /* private fields */ }

In-memory equality delete filter built from one or more delete files.

Each entry is column_name → set of string-normalised values to delete. A data row is deleted if, for every column in the filter, the row’s value is a member of that column’s set.

Implementations

impl EqualityDeleteFilter

pub async fn from_files( store: &Arc<dyn Store>, files: &[EqualityDeleteFile], ) -> AilakeResult<Self>

Build filter from a list of equality delete file references.

For each file, downloads the Avro payload from store and extracts (column_name, value) pairs. All files are merged into one filter.

pub fn empty() -> Self

pub fn is_empty(&self) -> bool

pub fn should_delete_row(&self, batch: &RecordBatch, row_idx: usize) -> bool

Check whether a single row (by its physical index in batch) matches the delete predicate.

Returns true if the row should be logically deleted. Iceberg equality delete semantics: a row is deleted only when ALL columns in the delete predicate match (AND, not OR). Used in the per-row HNSW result loop.

pub fn apply(&self, batch: RecordBatch) -> AilakeResult<RecordBatch>

Apply the filter to batch, returning a new batch with matching rows removed.

Iceberg equality delete semantics: a row is removed only when ALL columns in the delete predicate match (AND). Columns absent from the batch are ignored.