collect_left_input

datafusion_physical_plan::joins::nested_loop_join

Function collect_left_input 

Source 
async fn collect_left_input(
    stream: SendableRecordBatchStream,
    join_metrics: BuildProbeJoinMetrics,
    reservation: MemoryReservation,
    with_visited_left_side: bool,
    probe_threads_count: usize,
) -> Result<JoinLeftData>
Expand description

Asynchronously collect input into a single batch, and creates JoinLeftData from it