Struct ArrowGraph

pub struct ArrowGraph {
    pub nodes: RecordBatch,
    pub edges: RecordBatch,
    pub indexes: GraphIndexes,
}

Fields

nodes: RecordBatch

edges: RecordBatch

indexes: GraphIndexes

Implementations

impl ArrowGraph

pub fn new(nodes: RecordBatch, edges: RecordBatch) -> Result<Self>

Create a new graph from nodes and edges RecordBatches

pub fn from_edges(edges: RecordBatch) -> Result<Self>

Create a graph from just edges (nodes will be inferred)

pub fn empty() -> Result<Self>

Create an empty graph with no nodes or edges

pub async fn from_files<P: AsRef<Path>>( _nodes_path: P, _edges_path: P, ) -> Result<Self>

Load graph from Arrow/Parquet files

pub fn from_tables(nodes: RecordBatch, edges: RecordBatch) -> Result<Self>

Create graph from RecordBatches (alias for new)

pub async fn sql(&self, _query: &str) -> Result<RecordBatch>

Execute SQL query with graph functions

pub fn node_count(&self) -> usize

Get number of nodes in the graph

pub fn edge_count(&self) -> usize

Get number of edges in the graph

pub fn density(&self) -> f64

Calculate graph density (edges / max_possible_edges)

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

Get neighbors of a node

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

Get predecessors of a node (incoming edges)

pub fn has_node(&self, node_id: &str) -> bool

Check if node exists in graph

pub fn edge_weight(&self, source: &str, target: &str) -> Option<f64>

Get edge weight between two nodes

pub fn node_ids(&self) -> impl Iterator<Item = &String>

Get all node IDs

pub fn add_node(&mut self, node_id: String) -> Result<()>

Add a new node to the graph

pub fn remove_node(&mut self, node_id: &str) -> Result<()>

Remove a node from the graph (also removes all incident edges)

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

Add an edge to the graph

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

Remove an edge from the graph

Trait Implementations

impl Clone for ArrowGraph

fn clone(&self) -> ArrowGraph

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ArrowGraph

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

Formats the value using the given formatter.