build_side_determined_results

Function build_side_determined_results 

Source
pub(crate) fn build_side_determined_results(
    build_hash_joiner: &OneSideHashJoiner,
    output_schema: &SchemaRef,
    prune_length: usize,
    probe_schema: SchemaRef,
    join_type: JoinType,
    column_indices: &[ColumnIndex],
) -> Result<Option<RecordBatch>>
Expand description

This function produces unmatched record results based on the build side, join type and other parameters.

The method uses first prune_length rows from the build side input buffer to produce results.

§Arguments

  • output_schema - The schema of the final output record batch.
  • prune_length - The length of the determined prune length.
  • probe_schema - The schema of the probe [RecordBatch].
  • join_type - The type of join to be performed.
  • column_indices - Indices of columns that are being joined.

§Returns

  • Option<RecordBatch> - The final output record batch if required, otherwise None.