Struct SubscriptionFilter 

pub struct SubscriptionFilter {
    pub expression: String,
    pub ring0_predicates: Vec<Ring0Predicate>,
    pub ring1_predicates: Vec<Ring1Predicate>,
    pub intern_table: StringInternTable,
}

Compiled subscription filter.

Simple predicates are pushed to Ring 0 for zero-overhead filtering. Complex predicates are evaluated in Ring 1.

Fields

expression: String

Original filter expression.

ring0_predicates: Vec<Ring0Predicate>

Ring 0 predicates (simple, zero-allocation checks).

ring1_predicates: Vec<Ring1Predicate>

Ring 1 predicates (complex, may allocate).

intern_table: StringInternTable

Interned string table for Ring 0 string comparisons.

Implementations

impl SubscriptionFilter

pub fn evaluate_ring0(&self, batch: &RecordBatch, row: usize) -> bool

Evaluates all Ring 0 predicates against a single row.

Returns true if all predicates match (AND semantics). Returns true if there are no Ring 0 predicates.

pub fn has_ring1_predicates(&self) -> bool

Returns true if this filter has Ring 1 predicates that need evaluation.

pub fn has_predicates(&self) -> bool

Returns true if this filter has any predicates at all.

Trait Implementations

impl Clone for SubscriptionFilter

fn clone(&self) -> SubscriptionFilter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SubscriptionFilter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.