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: JoinType
Join type
join_constraint: JoinConstraint
Join constraint
schema: DFSchemaRef
The output schema, containing fields from the left and right inputs
null_equals_null: bool
If 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<Join> for Join
impl PartialEq<Join> for Join
impl Eq for Join
impl StructuralEq for Join
impl StructuralPartialEq for Join
Auto Trait Implementations§
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
§impl<Q, K> Equivalent<K> for Qwhere
Q: Eq + ?Sized,
K: Borrow<Q> + ?Sized,
impl<Q, K> Equivalent<K> for Qwhere Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Checks if this value is equivalent to the given key. Read more
§impl<Q, K> Equivalent<K> for Qwhere
Q: Eq + ?Sized,
K: Borrow<Q> + ?Sized,
impl<Q, K> Equivalent<K> for Qwhere Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.