Struct Predicate 

pub struct Predicate {
    exprs: Arc<Vec<Expr>>,
    dyn_filters: Arc<Vec<DynamicFilterPhysicalExpr>>,
}

Reference-counted pointer to a list of logical exprs and a list of dynamic filter physical exprs.

Fields

exprs: Arc<Vec<Expr>>

logical exprs

dyn_filters: Arc<Vec<DynamicFilterPhysicalExpr>>

dynamic filter physical exprs, only useful if dynamic filtering is enabled

They are usually from TopK or Join operators, and can dynamically filter data during query execution by using current runtime information to further reduce data scanning

Implementations

impl Predicate

pub fn new(exprs: Vec<Expr>) -> Self

Creates a new Predicate by converting logical exprs to physical exprs that can be evaluated against record batches. Returns error when failed to convert exprs.

pub fn with_dyn_filters( self, dyn_filters: Arc<Vec<DynamicFilterPhysicalExpr>>, ) -> Self

Sets the dynamic filter physical exprs.

pub fn exprs(&self) -> &[Expr]

Returns the logical exprs.

pub fn dyn_filters(&self) -> &Arc<Vec<DynamicFilterPhysicalExpr>>

Returns the dynamic filter physical exprs. Notice this return a live dynamic filters which can change during query execution.

pub fn dyn_filter_phy_exprs(&self) -> Result<Vec<Arc<dyn PhysicalExpr>>>

Returns the dynamic filter as physical exprs. Notice this return a “snapshot” of dynamic filters at the time of calling this method.

pub fn to_physical_exprs( &self, schema: &SchemaRef, ) -> Result<Vec<Arc<dyn PhysicalExpr>>>

Builds physical exprs according to provided schema.

pub fn prune_with_stats<S: PruningStatistics>( &self, stats: &S, schema: &SchemaRef, ) -> Vec<bool>

Evaluates the predicate against the stats. Returns a vector of boolean values, among which false means the row group can be skipped.

Trait Implementations

impl Clone for Predicate

fn clone(&self) -> Predicate

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Predicate

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

Formats the value using the given formatter.