Function datafusion_optimizer::utils::find_join_exprs
source · pub fn find_join_exprs(
exprs: Vec<&Expr>,
schema: &DFSchemaRef
) -> Result<(Vec<Expr>, Vec<Expr>)>
Expand description
Looks for correlating expressions: equality expressions with one field from the subquery, and one not in the subquery (closed upon from outer scope)
Arguments
exprs
- List of expressions that may or may not be joinsschema
- HashSet of fully qualified (table.col) fields in subquery schema
Return value
Tuple of (expressions containing joins, remaining non-join expressions)