Skip to main content

NestedLoopJoinOperator

Struct NestedLoopJoinOperator 

Source
pub struct NestedLoopJoinOperator { /* private fields */ }
Expand description

Nested Loop Join Operator.

For each row in the outer (left) input, scans all rows in the inner (right) input and emits matches based on the join condition.

Implementations§

Source§

impl NestedLoopJoinOperator

Source

pub fn new( left: Box<dyn Operator>, right: Box<dyn Operator>, join_type: JoinType, condition: Option<Expression>, ) -> Self

Create a new nested loop join operator.

§Arguments
  • left - Left (outer) input operator
  • right - Right (inner) input operator
  • join_type - Type of join (INNER, LEFT, RIGHT, FULL, CROSS)
  • condition - Join condition (None for CROSS JOIN)
Source

pub fn with_projection( self, columns: Vec<ColumnSource>, projected_schema: Vec<ColumnInfo>, ) -> Self

Set fused output projection.

Nested-loop still evaluates the join predicate against the full logical left/right rows. After that predicate boundary, projected output can be built directly, and unmatched OUTER rows can use sparse NULLs only for requested columns.

Trait Implementations§

Source§

impl Operator for NestedLoopJoinOperator

Source§

fn open(&mut self) -> Result<()>

Initialize the operator. Read more
Source§

fn next(&mut self) -> Result<Option<RowRef>>

Get the next row from this operator. Read more
Source§

fn close(&mut self) -> Result<()>

Close the operator and release resources. Read more
Source§

fn schema(&self) -> &[ColumnInfo]

Get the schema (column information) for this operator’s output.
Source§

fn estimated_rows(&self) -> Option<usize>

Get an estimate of the number of rows this operator will produce. Read more
Source§

fn name(&self) -> &str

Get a descriptive name for this operator (for EXPLAIN).
Source§

fn ordering(&self) -> OrderingProperty

Physical ordering guaranteed by this operator’s output. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CompactArcDrop for T

Source§

unsafe fn drop_and_dealloc(ptr: *mut u8)

Drop the contained data and deallocate the header+data allocation. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V