Struct ExternalSort 

pub struct ExternalSort { /* private fields */ }

External sort operator

Implements memory-bounded sorting with disk spilling.

Implementations

impl ExternalSort

pub fn new(controller: &Arc<MemoryController>) -> Self

Create a new external sort operator

pub fn with_config( controller: &Arc<MemoryController>, config: ExternalSortConfig, ) -> Self

Create with custom configuration

pub fn add_row(&mut self, row: Row, sort_keys: SortKey) -> Result<()>

Add a row with its sort keys to the sort operator

May trigger a spill if memory is exhausted.

pub fn finish(self) -> Result<SortedIterator>

Finalize sorting and return an iterator over sorted results

This completes the sort phase and prepares for the merge phase.

pub fn run_count(&self) -> usize

Get the number of runs created so far

pub fn total_rows(&self) -> usize

Get total rows added