build_buffered_data

datafusion_physical_plan::joins::piecewise_merge_join::exec

Function build_buffered_data 

Source 
async fn build_buffered_data(
    buffered: SendableRecordBatchStream,
    on_buffered: PhysicalExprRef,
    metrics: BuildProbeJoinMetrics,
    reservation: MemoryReservation,
    build_map: bool,
    remaining_partitions: usize,
) -> Result<BufferedSideData>