Struct MultiWayStreamMerge 

pub struct MultiWayStreamMerge { /* private fields */ }

Multi-way streaming merge of multiple spill files.

Reads N spill files + one optional in-memory buffer, merges them in sort-key order (ascending), and optionally deduplicates by primary key.

Implementations

impl MultiWayStreamMerge

pub fn new( spill_files: &[SpillFile], in_memory: Option<Vec<Vec<Value>>>, sort_key_col: usize, dedup: bool, ) -> Result<Self, StorageError>

Create a new multi-way stream merge.

• spill_files — list of spill files to read from disk.
• in_memory — optional final in-memory buffer (rows as Vec<Vec<Value>>).
• sort_key_col — column index to use as the sort/merge key.
• dedup — if true, consecutive duplicate sort keys are skipped.

pub fn next_tuple(&mut self) -> Option<Vec<Value>>

Get the next row from the merge.

Returns None when all sources are exhausted.