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 any delete predicate.

Returns true if the row should be logically deleted. Used in the per-row HNSW result loop where materializing a filtered batch would misalign row indices.

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

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

A row is removed when, for every column tracked by this filter that exists in the batch, the row’s value appears in the delete set for that column. Columns absent from the batch are ignored (no false deletes for schema-evolved files).