datafusion_expr::utils

Function add_filter

Source
pub fn add_filter(
    plan: LogicalPlan,
    predicates: &[&Expr],
) -> Result<LogicalPlan>
Expand description

Returns a new LogicalPlan that filters the output of plan with a LogicalPlan::Filter with all predicates ANDed.

ยงExample

Before:

plan

After:

Filter(predicate)
  plan