determine_prune_length

datafusion_physical_plan::joins::symmetric_hash_join

Function determine_prune_length 

Source 
fn determine_prune_length(
    buffer: &RecordBatch,
    build_side_filter_expr: &SortedFilterExpr,
) -> Result<usize>
Expand description

Determine the pruning length for buffer.

This function evaluates the build side filter expression, converts the result into an array and determines the pruning length by performing a binary search on the array.

§Arguments

  • buffer: The record batch to be pruned.
  • build_side_filter_expr: The filter expression on the build side used to determine the pruning length.

§Returns

A Result object that contains the pruning length. The function will return an error if

  • there is an issue evaluating the build side filter expression;
  • there is an issue converting the build side filter expression into an array