Function datafusion_physical_plan::sorts::streaming_merge::streaming_merge

source ยท 
pub fn streaming_merge(
    streams: Vec<SendableRecordBatchStream>,
    schema: SchemaRef,
    expressions: &[PhysicalSortExpr],
    metrics: BaselineMetrics,
    batch_size: usize,
    fetch: Option<usize>,
    reservation: MemoryReservation,
) -> Result<SendableRecordBatchStream>
Expand description

Perform a streaming merge of SendableRecordBatchStream based on provided sort expressions while preserving order.