Function replace_qualified_name

datafusion/optimizer/src/utils.rs:56–69

(
    expr: Expr,
    cols: &BTreeSet<Column>,
    subquery_alias: &str,
)

}

pub(crate) fn replace_qualified_name(
    expr: Expr,
    cols: &BTreeSet<Column>,
    subquery_alias: &str,
) -> Result<Expr> {
    let alias_cols: Vec<Column> = cols
        .iter()
        .map(|col| Column::new(Some(subquery_alias), &col.name))
        .collect();
    let replace_map: HashMap<&Column, &Column> =
        cols.iter().zip(alias_cols.iter()).collect();

    replace_col(expr, &replace_map)
}

/// Column reference to avoid copying string around
#[derive(PartialEq, Eq, Hash, Debug)]