Struct JoinLeftData 

pub(crate) struct JoinLeftData {
    batch: RecordBatch,
    bitmap: Mutex<BooleanBufferBuilder>,
    probe_threads_counter: AtomicUsize,
    reservation: MemoryReservation,
}

Left (build-side) data

Fields

batch: RecordBatch

Build-side data collected to single batch

bitmap: Mutex<BooleanBufferBuilder>

Shared bitmap builder for visited left indices

probe_threads_counter: AtomicUsize

Counter of running probe-threads, potentially able to update bitmap

reservation: MemoryReservation

Memory reservation for tracking batch and bitmap Cleared on JoinLeftData drop reservation is cleared on Drop

Implementations

impl JoinLeftData

pub(crate) fn new( batch: RecordBatch, bitmap: Mutex<BooleanBufferBuilder>, probe_threads_counter: AtomicUsize, reservation: MemoryReservation, ) -> Self

pub(crate) fn batch(&self) -> &RecordBatch

pub(crate) fn bitmap(&self) -> &Mutex<BooleanBufferBuilder>

pub(crate) fn report_probe_completed(&self) -> bool

Decrements counter of running threads, and returns true if caller is the last running thread