Struct IndexNestedLoopJoinOperator 

pub struct IndexNestedLoopJoinOperator { /* private fields */ }

Index Nested Loop Join Operator.

For each row in the outer input, looks up matching rows in the inner table using an index. This avoids full table scans of the inner table.

Implementations

impl IndexNestedLoopJoinOperator

pub fn new( outer: Box<dyn Operator>, inner_table: Box<dyn Table>, inner_schema: Vec<ColumnInfo>, join_type: JoinType, outer_key_idx: usize, lookup_strategy: IndexLookupStrategy, residual_filter: Option<JoinFilter>, ) -> Self

Create a new index nested loop join operator.

Arguments

• outer - Outer input operator
• inner_table - Inner table to lookup from
• inner_schema - Schema of the inner table
• join_type - Type of join (INNER or LEFT)
• outer_key_idx - Column index of the join key in outer rows
• lookup_strategy - How to find matching inner rows
• residual_filter - Optional additional filter after key match

pub fn with_cancellation(self, cancellation: CancellationHandle) -> Self

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

Set projection pushdown configuration.

When set, the operator creates projected rows directly during the combine step instead of creating full combined rows. This avoids creating large intermediate rows that would be immediately projected down to fewer columns.

Arguments

• columns - Column sources in SELECT order (preserves original column ordering)
• projected_schema - Schema for the projected output

Trait Implementations

impl Operator for IndexNestedLoopJoinOperator

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

Initialize the operator.

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

Get the next row from this operator.

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

Close the operator and release resources.

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

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

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

Get an estimate of the number of rows this operator will produce.

fn ordering(&self) -> OrderingProperty

Physical ordering guaranteed by this operator’s output.

fn name(&self) -> &str

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