Method join_on

datafusion/expr/src/logical_plan/builder.rs:984–999

Apply a join using the specified expressions. Note that DataFusion automatically optimizes joins, including identifying and optimizing equality predicates. # Example ``` # use datafusion_expr::{Expr, col, LogicalPlanBuilder, # logical_plan::builder::LogicalTableSource, logical_plan::JoinType,}; # use std::sync::Arc; # use arrow::datatypes::{Schema, DataType, Field}; # use datafusion_common::Re

(
        self,
        right: LogicalPlan,
        join_type: JoinType,
        on_exprs: impl IntoIterator<Item = Expr>,
    )

    /// # }
    /// ```
    pub fn join_on(
        self,
        right: LogicalPlan,
        join_type: JoinType,
        on_exprs: impl IntoIterator<Item = Expr>,
    ) -> Result<Self> {
        let filter = on_exprs.into_iter().reduce(Expr::and);

        self.join_detailed(
            right,
            join_type,
            (Vec::<Column>::new(), Vec::<Column>::new()),
            filter,
            NullEquality::NullEqualsNothing,
        )
    }

    pub(crate) fn normalize(plan: &LogicalPlan, column: Column) -> Result<Column> {
        if column.relation.is_some() {