Struct datafusion_optimizer::decorrelate::PullUpCorrelatedExpr

pub struct PullUpCorrelatedExpr {
    pub join_filters: Vec<Expr>,
    pub correlated_subquery_cols_map: HashMap<LogicalPlan, BTreeSet<Column>>,
    pub in_predicate_opt: Option<Expr>,
    pub exists_sub_query: bool,
    pub can_pull_up: bool,
    pub need_handle_count_bug: bool,
    pub collected_count_expr_map: HashMap<LogicalPlan, ExprResultMap>,
    pub pull_up_having_expr: Option<Expr>,
}

This struct rewrite the sub query plan by pull up the correlated expressions(contains outer reference columns) from the inner subquery’s ‘Filter’. It adds the inner reference columns to the ‘Projection’ or ‘Aggregate’ of the subquery if they are missing, so that they can be evaluated by the parent operator as the join condition.

Fields

join_filters: Vec<Expr>

correlated_subquery_cols_map: HashMap<LogicalPlan, BTreeSet<Column>>

in_predicate_opt: Option<Expr>

exists_sub_query: bool

can_pull_up: bool

need_handle_count_bug: bool

collected_count_expr_map: HashMap<LogicalPlan, ExprResultMap>

pull_up_having_expr: Option<Expr>

Trait Implementations

impl TreeNodeRewriter for PullUpCorrelatedExpr

type N = LogicalPlan

The node type which is rewritable.

fn pre_visit(&mut self, plan: &LogicalPlan) -> Result<RewriteRecursion>

Invoked before (Preorder) any children of node are rewritten / visited. Default implementation returns Ok(Recursion::Continue)

fn mutate(&mut self, plan: LogicalPlan) -> Result<LogicalPlan>

Invoked after (Postorder) all children of node have been mutated and returns a potentially modified node.