Struct ParallelHashJoinOperator 

pub struct ParallelHashJoinOperator { /* private fields */ }

Pull-based parallel hash join.

The build table is parallel and immutable. Probe work is admitted in a bounded batch, and each Rayon round advances every live probe cursor by at most one output match. The round therefore retains only O(batch rows) fixed-width candidate descriptors, never a full JOIN result or an unbounded per-key fan-out vector.

Implementations

impl ParallelHashJoinOperator

pub fn new( probe: Box<dyn Operator>, build_rows: CompactArc<Vec<Row>>, build_key_indices: Vec<usize>, probe_key_indices: Vec<usize>, join_type: JoinType, build_is_left: bool, left_col_count: usize, right_col_count: usize, columns: Vec<String>, projection: Option<Vec<ColumnSource>>, config: ParallelConfig, cancellation: CancellationHandle, hash_state_bytes: usize, hash_state_reservation: JoinMemoryReservation, batch_reservation: JoinMemoryReservation, ) -> Result<Self>

pub fn observed_probe_rows(&self) -> u64

pub fn observed_candidate_rows(&self) -> u64

Trait Implementations

impl Operator for ParallelHashJoinOperator

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