Struct OrderByMerger 

pub struct OrderByMerger { /* private fields */ }

N-way merge-sort merger for distributed ORDER BY + LIMIT.

Implementations

impl OrderByMerger

pub fn new(direction: SortDirection) -> Self

pub fn add_shard_rows(&mut self, rows: Vec<ShardRow>)

Add a shard’s locally-sorted, locally-limited rows.

pub fn merge(&mut self, global_limit: usize) -> Vec<ShardRow>

Perform the global merge sort and apply the global LIMIT.

Each shard already applied ORDER BY + LIMIT locally, so we have at most num_shards × limit rows. The global sort + limit produces the correct result.

pub fn total_rows(&self) -> usize

Total rows collected before merge.