Struct MergeJoinOperator 

pub struct MergeJoinOperator { /* private fields */ }

Merge Join Operator for pre-sorted inputs.

Both inputs must be sorted on their respective join keys. The operator performs a single pass through both inputs, producing matches as they’re found.

Implementations

impl MergeJoinOperator

pub fn new( left: Box<dyn Operator>, right: Box<dyn Operator>, join_type: JoinType, left_key_indices: Vec<usize>, right_key_indices: Vec<usize>, ) -> Self

Create a new merge join operator.

Arguments

• left - Left input operator (must be sorted on left_key_indices)
• right - Right input operator (must be sorted on right_key_indices)
• join_type - Type of join (INNER, LEFT, RIGHT, FULL - NOT Cross)
• left_key_indices - Column indices for left join keys
• right_key_indices - Column indices for right join keys

Panics

Debug builds will panic if join_type is JoinType::Cross. Cross joins should use NestedLoopJoinOperator instead.

Trait Implementations

impl Operator for MergeJoinOperator

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