Struct PredicateRewriter 

pub struct PredicateRewriter { /* private fields */ }

Rewrite a predicate expression in terms of statistics (min/max/null_counts) for use as a PruningPredicate.

Implementations

impl PredicateRewriter

pub fn new() -> Self

Create a new PredicateRewriter

pub fn with_unhandled_hook( self, unhandled_hook: Arc<dyn UnhandledPredicateHook>, ) -> Self

Set the unhandled hook to be used when a predicate can not be rewritten

pub fn with_max_in_list_size(self, max_in_list_size: usize) -> Self

Set the maximum size of an IN (...) list that will be rewritten into a chain of per-value statistics checks. Lists longer than this fall back to the unhandled-predicate hook (typically “keep the container”), effectively skipping container-level pruning for large IN lists.

The default (see MAX_IN_LIST_SIZE) preserves the historical behaviour. Callers wiring config through can override via datafusion.execution.max_in_list_size.

pub fn rewrite_predicate_to_statistics_predicate( &self, expr: &Arc<dyn PhysicalExpr>, schema: &Schema, ) -> Arc<dyn PhysicalExpr>

Translate logical filter expression into pruning predicate expression that will evaluate to FALSE if it can be determined no rows between the min/max values could pass the predicates.

Any predicates that can not be translated will be passed to unhandled_hook.

Returns the pruning predicate as an PhysicalExpr

Notice: IN (...) lists longer than max_in_list_size (default MAX_IN_LIST_SIZE) fall back to calling unhandled_hook.

Trait Implementations

impl Default for PredicateRewriter

fn default() -> Self

Returns the “default value” for a type.