Struct StreamingConnectedComponents

pub struct StreamingConnectedComponents { /* private fields */ }

Streaming Connected Components algorithm that updates incrementally

Implementations

impl StreamingConnectedComponents

pub fn new() -> Self

pub fn component_of(&self, node_id: &str) -> Option<&String>

Get the component ID for a node

pub fn component_size(&self, node_id: &str) -> Option<usize>

Get the size of the component containing a node

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

Get all components and their sizes

pub fn component_count(&self) -> usize

Get number of components

Trait Implementations

impl Clone for StreamingConnectedComponents

fn clone(&self) -> StreamingConnectedComponents

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamingConnectedComponents

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

Formats the value using the given formatter.

impl Default for StreamingConnectedComponents

fn default() -> Self

Returns the “default value” for a type.

impl StreamingAlgorithm<HashMap<String, String>> for StreamingConnectedComponents

fn initialize(&mut self, processor: &IncrementalGraphProcessor) -> Result<()>

Initialize the algorithm with the current graph state

fn update( &mut self, processor: &IncrementalGraphProcessor, changes: &UpdateResult, ) -> Result<()>

Update the algorithm state based on graph changes

fn get_result(&self) -> &HashMap<String, String>

Get the current result/state of the algorithm

fn recompute(&mut self, processor: &IncrementalGraphProcessor) -> Result<()>

Force a full recomputation (fallback when incremental update is not sufficient)

fn needs_recomputation(&self, changes: &UpdateResult) -> bool

Check if the algorithm needs full recomputation