get_pruning_anti_indices

datafusion_physical_plan::joins::stream_join_utils

Function get_pruning_anti_indices 

Source 
pub fn get_pruning_anti_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

Get the anti join indices from the visited hash set.

This method returns the indices from the original input that were not 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 anti join indices.