Struct BatchIndexNestedLoopJoinOperator 

pub struct BatchIndexNestedLoopJoinOperator { /* private fields */ }

Bounded batch Index-NL operator.

A fixed-size outer chunk is collected, lookup keys are deduplicated, and matching inner rows are fetched once for the whole chunk. Results remain streamed in outer-row order; the operator never retains the complete outer input or complete join output.

Implementations

impl BatchIndexNestedLoopJoinOperator

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 batch index nested loop join operator.

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 BatchIndexNestedLoopJoinOperator

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).