Skip to main content

delete_nodes

graphforge_storage::mutator

Function delete_nodes 

Source 
pub fn delete_nodes<S: BuildHasher>(
    dir: &Path,
    node_uuids: &HashSet<[u8; 16], S>,
) -> Result<u64, GfError>
Expand description

Delete the given nodes by node_uuid, rewriting topology/nodes.parquet and dropping the same nodes’ rows from every properties/*.parquet file.

All rewrites stage and commit as one batch, topology/nodes.parquet last (#790): a failure while building the replacement files leaves the prior state fully intact.

Returns the number of node rows removed. Does not touch edges — callers enforce openCypher’s “no relationships without DETACH” rule (see incident_edge_uuids) and delete incident edges via delete_edges.

§Errors

Returns GfError::Storage on any I/O, Arrow, or Parquet failure.