Method apply_merges

nodedb-cluster/src/distributed_graph/wcc.rs:140–173

Apply incoming merges. Returns number of labels changed.

(&mut self, merges: &[(String, String)])

    /// Apply incoming merges. Returns number of labels changed.
    pub fn apply_merges(&mut self, merges: &[(String, String)]) -> usize {
        let mut changed = 0;

        let name_to_id: HashMap<&str, usize> = self
            .node_names
            .iter()
            .enumerate()
            .map(|(i, n)| (n.as_str(), i))
            .collect();

        for (vertex_name, remote_label) in merges {
            let Some(&local_id) = name_to_id.get(vertex_name.as_str()) else {
                continue;
            };

            let root = find_static(&self.parent, local_id);
            let local_label = &self.global_labels[root];

            if local_label != remote_label && *remote_label < *local_label {
                self.global_labels[root] = remote_label.clone();
                changed += 1;
            }
        }

        // Propagate updated labels to all nodes.
        for i in 0..self.vertex_count {
            let root = find_static(&self.parent, i);
            if i != root {
                self.global_labels[i] = self.global_labels[root].clone();
            }
        }

        changed
    }

    /// Get current component assignment: (vertex_name, global_label).
    pub fn component_labels(&self) -> Vec<(String, String)> {