Struct ShardWccState 

pub struct ShardWccState {
    pub vertex_count: usize,
    pub global_labels: Vec<String>,
    pub shard_id: u32,
    pub boundary_edges: HashMap<u32, Vec<(String, u32)>>,
    /* private fields */
}

Per-shard WCC execution state.

Fields

vertex_count: usize

global_labels: Vec<String>

shard_id: u32

boundary_edges: HashMap<u32, Vec<(String, u32)>>

Implementations

impl ShardWccState

pub fn init( vertex_count: usize, shard_id: u32, node_names: Vec<String>, local_edges: &dyn Fn(u32) -> Vec<u32>, ghost_edges: &dyn Fn(u32) -> Vec<(String, u32)>, ) -> Self

Initialize WCC state for a local CSR partition.

pub fn round(&self) -> (HashMap<u32, Vec<(String, String)>>, usize)

Produce outbound merge requests for boundary edges.

pub fn apply_merges(&mut self, merges: &[(String, String)]) -> usize

Apply incoming merges. Returns number of labels changed.

pub fn component_labels(&self) -> Vec<(String, String)>

Get current component assignment: (vertex_name, global_label).

Trait Implementations

impl Debug for ShardWccState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.