Struct OneSideHashJoiner 

pub struct OneSideHashJoiner {
    build_side: JoinSide,
    pub input_buffer: RecordBatch,
    pub(crate) on: Vec<PhysicalExprRef>,
    pub(crate) hashmap: PruningJoinHashMap,
    pub(crate) hashes_buffer: Vec<u64>,
    pub(crate) visited_rows: HashSet<usize>,
    pub(crate) offset: usize,
    pub(crate) deleted_offset: usize,
}

Fields

build_side: JoinSide

Build side

input_buffer: RecordBatch

Input record batch buffer

on: Vec<PhysicalExprRef>

Columns from the side

hashmap: PruningJoinHashMap

Hashmap

hashes_buffer: Vec<u64>

Reuse the hashes buffer

visited_rows: HashSet<usize>

Matched rows

offset: usize

Offset

deleted_offset: usize

Deleted offset

Implementations

impl OneSideHashJoiner

pub fn size(&self) -> usize

pub fn new( build_side: JoinSide, on: Vec<PhysicalExprRef>, schema: SchemaRef, ) -> Self

pub(crate) fn update_internal_state( &mut self, batch: &RecordBatch, random_state: &RandomState, ) -> Result<()>

Updates the internal state of the OneSideHashJoiner with the incoming batch.

Arguments

• batch - The incoming [RecordBatch] to be merged with the internal input buffer
• random_state - The random state used to hash values

Returns

Returns a Result encapsulating any intermediate errors.

pub(crate) fn calculate_prune_length_with_probe_batch( &mut self, build_side_sorted_filter_expr: &mut SortedFilterExpr, probe_side_sorted_filter_expr: &mut SortedFilterExpr, graph: &mut ExprIntervalGraph, ) -> Result<usize>

Calculate prune length.

Arguments

• build_side_sorted_filter_expr - Build side mutable sorted filter expression..
• probe_side_sorted_filter_expr - Probe side mutable sorted filter expression.
• graph - A mutable reference to the physical expression graph.

Returns

A Result object that contains the pruning length.

pub(crate) fn prune_internal_state(&mut self, prune_length: usize) -> Result<()>