Struct DynamicFilterInner 

pub struct DynamicFilterInner {
    pub expression_id: u64,
    pub generation: u64,
    pub expr: Arc<dyn PhysicalExpr>,
    pub is_complete: bool,
}

Atomic internal state of a DynamicFilterPhysicalExpr.

expression_id lives here because it identifies the actual filter expression expr. Derived DynamicFilterPhysicalExprs (e.g. via PhysicalExpr::with_new_children) are the same logical filter and must report the same expression_id.

Warning: exposed publicly solely so that proto (de)serialization in datafusion-proto can read and rebuild this state. Do not treat this type or its layout as a stable API.

Fields

expression_id: u64

A unique identifier for the expression.

generation: u64

A counter that gets incremented every time the expression is updated so that we can track changes cheaply. This is used for PhysicalExpr::snapshot_generation to have a cheap check for changes.

expr: Arc<dyn PhysicalExpr>

is_complete: bool

Flag for quick synchronous check if filter is complete. This is redundant with the watch channel state, but allows us to return immediately from wait_complete() without subscribing if already complete.

Trait Implementations

impl Clone for Inner

fn clone(&self) -> Inner

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Inner

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

Formats the value using the given formatter.