Method top_k

nodedb-cluster/src/distributed_vector/merge.rs:77–86

Merge all shard results and return the global top-K. Sorts by distance ascending (nearest first) and truncates to `top_k`. Ties are broken by shard_id for deterministic ordering.

(&mut self, top_k: usize)

    /// Sorts by distance ascending (nearest first) and truncates to `top_k`.
    /// Ties are broken by shard_id for deterministic ordering.
    pub fn top_k(&mut self, top_k: usize) -> Vec<VectorHit> {
        self.all_hits.sort_by(|a, b| {
            a.distance
                .partial_cmp(&b.distance)
                .unwrap_or(std::cmp::Ordering::Equal)
                .then(a.shard_id.cmp(&b.shard_id))
        });
        self.all_hits.truncate(top_k);
        self.all_hits.clone()
    }

    /// Number of total hits collected (before merge).
    pub fn total_hits(&self) -> usize {