get_pruning_semi_indices

datafusion_physical_plan::joins::stream_join_utils

Function get_pruning_semi_indices 

Source 
pub fn get_pruning_semi_indices<T: ArrowPrimitiveType>(
    prune_length: usize,
    deleted_offset: usize,
    visited_rows: &HashSet<usize>,
) -> PrimitiveArray<T>
where
    NativeAdapter<T>: From<<T as ArrowPrimitiveType>::Native>,
Expand description

This method creates a boolean buffer from the visited rows hash set and the indices of the pruned record batch slice.

It gets the indices from the original input that were present in the visited hash set.

§Arguments

  • prune_length - The length of the pruned record batch.
  • deleted_offset - The offset to the indices.
  • visited_rows - The hash set of visited indices.

§Returns

A [PrimitiveArray] of the specified type T, containing the semi indices.