Function scatter_native

datafusion/physical-expr-common/src/utils.rs:149–172

(
    src: &[T],
    mask: &BooleanBuffer,
    output_len: usize,
    selectivity: f64,
)

#[inline(never)]
fn scatter_native<T: ArrowNativeType>(
    src: &[T],
    mask: &BooleanBuffer,
    output_len: usize,
    selectivity: f64,
) -> ScalarBuffer<T> {
    let mut output = vec![T::default(); output_len];
    let mut src_offset = 0;

    if selectivity > SCATTER_SLICES_SELECTIVITY_THRESHOLD {
        for (start, end) in mask.set_slices() {
            let len = end - start;
            output[start..end].copy_from_slice(&src[src_offset..src_offset + len]);
            src_offset += len;
        }
    } else {
        for dst_idx in mask.set_indices() {
            output[dst_idx] = src[src_offset];
            src_offset += 1;
        }
    }

    ScalarBuffer::from(output)
}

fn scatter_bits(
    src: &BooleanBuffer,