Struct Join 

pub struct Join {
    pub join_type: JoinType,
    pub on_condition: Option<Expr>,
    pub left_alias: Option<String>,
    pub right_alias: Option<String>,
}

Join operator with proper condition evaluation.

Fields

join_type: JoinType

Join type.

on_condition: Option<Expr>

Join condition.

left_alias: Option<String>

Left table alias.

right_alias: Option<String>

Right table alias.

Implementations

impl Join

pub fn new(join_type: JoinType, on_condition: Option<Expr>) -> Self

Create a new join.

pub fn with_left_alias(self, alias: impl Into<String>) -> Self

Set left table alias.

pub fn with_right_alias(self, alias: impl Into<String>) -> Self

Set right table alias.

pub fn execute( &self, left: &RecordBatch, right: &RecordBatch, ) -> Result<RecordBatch>

Execute the join.