Struct datafusion_expr::logical_plan::Join
source · pub struct Join {
pub left: Arc<LogicalPlan>,
pub right: Arc<LogicalPlan>,
pub on: Vec<(Expr, Expr)>,
pub filter: Option<Expr>,
pub join_type: JoinType,
pub join_constraint: JoinConstraint,
pub schema: DFSchemaRef,
pub null_equals_null: bool,
}Expand description
Join two logical plans on one or more join columns
Fields§
§left: Arc<LogicalPlan>Left input
right: Arc<LogicalPlan>Right input
on: Vec<(Expr, Expr)>Equijoin clause expressed as pairs of (left, right) join expressions
filter: Option<Expr>Filters applied during join (non-equi conditions)
join_type: JoinTypeJoin type
join_constraint: JoinConstraintJoin constraint
schema: DFSchemaRefThe output schema, containing fields from the left and right inputs
null_equals_null: boolIf null_equals_null is true, null == null else null != null
Implementations§
source§impl Join
impl Join
sourcepub fn try_new_with_project_input(
original: &LogicalPlan,
left: Arc<LogicalPlan>,
right: Arc<LogicalPlan>,
column_on: (Vec<Column>, Vec<Column>),
) -> Result<Self>
pub fn try_new_with_project_input( original: &LogicalPlan, left: Arc<LogicalPlan>, right: Arc<LogicalPlan>, column_on: (Vec<Column>, Vec<Column>), ) -> Result<Self>
Create Join with input which wrapped with projection, this method is used to help create physical join.
Trait Implementations§
source§impl PartialEq for Join
impl PartialEq for Join
impl Eq for Join
impl StructuralPartialEq for Join
Auto Trait Implementations§
impl Freeze for Join
impl !RefUnwindSafe for Join
impl Send for Join
impl Sync for Join
impl Unpin for Join
impl !UnwindSafe for Join
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.