Module filter 

Structs

FilterExec

FilterExec evaluates a boolean predicate against all input batches to determine which rows to include in its output batches.

FilterExecMetrics 🔒

The metrics for FilterExec

FilterExecStream 🔒

The FilterExec streams wraps the input iterator and applies the predicate expression to determine which rows to include in its output batches

Constants

FILTER_EXEC_DEFAULT_SELECTIVITY 🔒

Functions

batch_filter

collect_columns_from_predicateDeprecated

Return the equals Column-Pairs and Non-equals Column-Pairs

collect_columns_from_predicate_inner 🔒

collect_new_statistics 🔒

This function ensures that all bounds in the ExprBoundaries vector are converted to closed bounds. If a lower/upper bound is initially open, it is adjusted by using the next/previous value for its data type to convert it into a closed bound.

filter_and_project 🔒

Type Aliases

EqualAndNonEqual

The equals Column-Pairs and Non-equals Column-Pairs in the Predicates

PhysicalExprPairRef

Pair of Arc<dyn PhysicalExpr>s