Struct TopKDynamicFilters 

pub struct TopKDynamicFilters {
    threshold_row: Option<Vec<u8>>,
    expr: Arc<DynamicFilterPhysicalExpr>,
}

Fields

threshold_row: Option<Vec<u8>>

The current global threshold for the dynamic filter. This is shared across all partitions and is updated by any of them. Stored as row bytes for efficient comparison.

expr: Arc<DynamicFilterPhysicalExpr>

The expression used to evaluate the dynamic filter Only updated when lock held for the duration of the update

Implementations

impl TopKDynamicFilters

pub fn new(expr: Arc<DynamicFilterPhysicalExpr>) -> Self

Create a new TopKDynamicFilters with the given expression

pub fn expr(&self) -> Arc<DynamicFilterPhysicalExpr>

Trait Implementations

impl Clone for TopKDynamicFilters

fn clone(&self) -> TopKDynamicFilters

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TopKDynamicFilters

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

Formats the value using the given formatter.