Struct IncrementalGraphProcessor

pub struct IncrementalGraphProcessor { /* private fields */ }

Incremental graph update operations for streaming graph processing Supports efficient add/remove of vertices and edges with minimal recomputation

Implementations

impl IncrementalGraphProcessor

pub fn new(graph: ArrowGraph) -> Result<Self>

Create a new incremental processor from an existing graph

pub fn set_batch_size(&mut self, size: usize)

Set the batch size for operations

pub fn add_vertex(&mut self, vertex_id: String) -> Result<()>

Add a vertex to the graph (batched)

pub fn remove_vertex(&mut self, vertex_id: String) -> Result<()>

Remove a vertex from the graph (batched)

pub fn add_edge( &mut self, source: String, target: String, weight: f64, ) -> Result<()>

Add an edge to the graph (batched)

pub fn remove_edge(&mut self, source: String, target: String) -> Result<()>

Remove an edge from the graph (batched)

pub fn apply_updates( &mut self, operations: Vec<UpdateOperation>, ) -> Result<UpdateResult>

Apply a batch of update operations

pub fn flush_all_operations(&mut self) -> Result<UpdateResult>

Flush all pending operations and rebuild the graph

pub fn graph(&self) -> &ArrowGraph

Get the current graph

pub fn pending_operations_count(&self) -> usize

Get the number of pending operations

pub fn has_pending_operations(&self) -> bool

Check if there are pending operations

pub fn statistics(&self) -> IncrementalStats

Get statistics about the current state

Trait Implementations

impl Clone for IncrementalGraphProcessor

fn clone(&self) -> IncrementalGraphProcessor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IncrementalGraphProcessor

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

Formats the value using the given formatter.