pub fn merge_streams(streams: Vec<ReadBatchTaskStream>) -> ReadBatchTaskStream
Expand description
Given multiple streams of batch tasks, merge them into a single stream
This pulls one batch from each stream and then combines the columns from all of the batches into a single batch. The order of the batches in the streams is maintained and the merged batch columns will be in order from first to last stream.
This stream ends as soon as any of the input streams ends (we do not verify that the other input streams are finished as well)
This will panic if any of the input streams return a batch with a different number of rows than the first stream.