Struct MainVertexDataset 

pub struct MainVertexDataset { /* private fields */ }

Main vertex dataset for the unified vertices table.

This table contains all vertices regardless of label, providing:

• Fast ID-based lookups without knowing the label
• Global ext_id uniqueness enforcement
• Multi-label storage with labels as a list column

Implementations

impl MainVertexDataset

pub fn new(base_uri: &str) -> MainVertexDataset

Create a new MainVertexDataset.

pub fn get_arrow_schema() -> Arc<Schema>

Get the Arrow schema for the main vertices table.

pub fn table_name() -> &'static str

Get the table name for the main vertices table.

pub fn build_record_batch( vertices: &[(Vid, Vec<String>, HashMap<String, Value>, bool, u64)], created_at: Option<&HashMap<Vid, i64>>, updated_at: Option<&HashMap<Vid, i64>>, ) -> Result<RecordBatch, Error>

Build a record batch for the main vertices table.

Arguments

• vertices - List of (vid, labels, properties, deleted, version) tuples
• created_at - Optional map of Vid -> nanoseconds since epoch
• updated_at - Optional map of Vid -> nanoseconds since epoch

pub async fn write_batch( backend: &(dyn StorageBackend + 'static), batch: RecordBatch, ) -> Result<(), Error>

Write a batch to the main vertices table.

Creates the table if it doesn’t exist, otherwise appends to it.

pub async fn ensure_default_indexes( backend: &(dyn StorageBackend + 'static), ) -> Result<(), Error>

Ensure default indexes exist on the main vertices table.

pub async fn find_by_ext_id( backend: &(dyn StorageBackend + 'static), ext_id: &str, version: Option<u64>, ) -> Result<Option<Vid>, Error>

Query the main vertices table for a vertex by ext_id.

Returns the Vid if found, None otherwise.

Arguments

• version - Optional version high water mark for snapshot isolation. Pass None for writer uniqueness checks (global visibility). Pass Some(hwm) for query-time snapshot isolation.

pub async fn ext_id_exists( backend: &(dyn StorageBackend + 'static), ext_id: &str, version: Option<u64>, ) -> Result<bool, Error>

Check if an ext_id already exists in the main vertices table.

Arguments

• version - Optional version high water mark for snapshot isolation.

pub async fn find_labels_by_vid( backend: &(dyn StorageBackend + 'static), vid: Vid, version: Option<u64>, ) -> Result<Option<Vec<String>>, Error>

Find labels for a vertex by VID in the main vertices table.

Returns the list of labels if found, None otherwise.

Arguments

• version - Optional version high water mark for snapshot isolation.

pub async fn find_all_vids( backend: &(dyn StorageBackend + 'static), version: Option<u64>, ) -> Result<Vec<Vid>, Error>

Find all non-deleted VIDs in the main vertices table.

Returns all VIDs where _deleted = false.

Arguments

• version - Optional version high water mark for snapshot isolation.

Errors

Returns an error if the table query fails.

pub async fn find_vids_by_label_name( backend: &(dyn StorageBackend + 'static), label: &str, version: Option<u64>, ) -> Result<Vec<Vid>, Error>

Find VIDs by label name in the main vertices table.

Searches for vertices where the labels array contains the given label and _deleted = false.

Arguments

• version - Optional version high water mark for snapshot isolation.

Errors

Returns an error if the table query fails.

pub async fn find_vids_by_labels( backend: &(dyn StorageBackend + 'static), labels: &[&str], version: Option<u64>, ) -> Result<Vec<Vid>, Error>

Find VIDs by multiple label names (intersection semantics).

Returns vertices that have ALL the specified labels. Uses array_contains(labels, 'A') AND array_contains(labels, 'B') filtering.

Arguments

• version - Optional version high water mark for snapshot isolation.

pub async fn find_batch_props_by_vids( backend: &(dyn StorageBackend + 'static), vids: &[Vid], version: Option<u64>, ) -> Result<HashMap<Vid, HashMap<String, Value>>, Error>

Batch-fetch properties for multiple VIDs from the main vertices table.

Returns a HashMap mapping VIDs to their parsed properties. Non-deleted vertices are returned with properties from props_json. This is used for schemaless vertex scans via DataFusion.

Arguments

• version - Optional version high water mark for snapshot isolation.

Errors

Returns an error if the table query fails or JSON parsing fails.

pub async fn find_props_by_vid( backend: &(dyn StorageBackend + 'static), vid: Vid, version: Option<u64>, ) -> Result<Option<HashMap<String, Value>>, Error>

Find properties for a vertex by VID in the main vertices table.

Returns the props_json parsed into a Properties HashMap if found. This is used as a fallback for unknown/schemaless labels.

Arguments

• version - Optional version high water mark for snapshot isolation.

Errors

Returns an error if the table query fails or JSON parsing fails.

pub async fn find_batch_labels_by_vids( backend: &(dyn StorageBackend + 'static), vids: &[Vid], version: Option<u64>, ) -> Result<HashMap<Vid, Vec<String>>, Error>

Batch-fetch labels for multiple VIDs from the main vertices table.

Arguments

• version - Optional version high water mark for snapshot isolation.

Trait Implementations

impl Debug for MainVertexDataset

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

Formats the value using the given formatter.