Struct ArrowGraphStore 

pub struct ArrowGraphStore { /* private fields */ }

Convenience re-export of the core store types using string-based namespaces. The core Arrow-native graph store, partitioned by namespace.

Each namespace holds a vector of RecordBatches (appended over time). Queries filter by namespace first, then by column predicates.

Namespaces are arbitrary strings defined at construction time.

Implementations

impl ArrowGraphStore

pub fn new(namespaces: &[&str]) -> ArrowGraphStore

Create a new empty store with the given namespace partitions.

Example

use arrow_graph_core::store::ArrowGraphStore;

// Knowledge graph with three partitions
let store = ArrowGraphStore::new(&["world", "code", "self"]);

// Document store with different partitions
let store = ArrowGraphStore::new(&["drafts", "published"]);

pub fn schema(&self) -> &Arc<Schema>

Get the triples schema.

pub fn namespaces(&self) -> &[String]

Get the list of namespace names.

pub fn add_triple( &mut self, triple: &Triple, namespace: &str, layer: Option<u8>, ) -> Result<String, StoreError>

Add a single triple to the specified namespace and layer.

The layer parameter is optional — pass None to use layer 0 (default).

pub fn add_batch( &mut self, triples: &[Triple], namespace: &str, layer: Option<u8>, ) -> Result<Vec<String>, StoreError>

Add a batch of triples to the specified namespace and layer. Returns the generated triple IDs.

pub fn query(&self, spec: &QuerySpec) -> Result<Vec<RecordBatch>, StoreError>

Query triples matching the given spec.

pub fn len(&self) -> usize

Total number of non-deleted triples across all namespaces.

pub fn is_empty(&self) -> bool

Whether the store has no non-deleted triples.

pub fn len_all(&self) -> usize

Total number of triples including deleted.

pub fn delete(&mut self, triple_id: &str) -> Result<bool, StoreError>

Logically delete a triple by ID (sets deleted=true).

pub fn get_namespace_batches(&self, namespace: &str) -> &[RecordBatch]

Get all RecordBatches for a given namespace (including deleted triples).

pub fn set_namespace_batches( &mut self, namespace: &str, batches: Vec<RecordBatch>, )

Replace all data for a namespace (used by checkout/restore).

pub fn causal_chain(&self, triple_id: &str) -> Vec<CausalNode>

Follow the caused_by/derived_from chain from a triple to build a derivation graph.

Returns a list of causal nodes representing the full ancestry of the given triple. The first element is always the queried triple itself. Traversal is breadth-first.

pub fn clear(&mut self)

Clear all data from the store.