Struct VertexDataset 

pub struct VertexDataset { /* private fields */ }

Implementations

impl VertexDataset

pub fn new(base_uri: &str, label: &str, label_id: u16) -> VertexDataset

pub fn compute_vertex_uid( label: &str, ext_id: Option<&str>, properties: &HashMap<String, Value>, ) -> UniId

Compute UniId from vertex content. Canonical form: sorted JSON of (label, ext_id, properties)

pub async fn open(&self) -> Result<Arc<Dataset>, Error>

pub async fn open_at(&self, version: Option<u64>) -> Result<Arc<Dataset>, Error>

pub async fn open_raw(&self) -> Result<Dataset, Error>

pub fn build_record_batch( &self, vertices: &[(Vid, Vec<String>, HashMap<String, Value>)], deleted: &[bool], versions: &[u64], schema: &Schema, ) -> Result<RecordBatch, Error>

Build a record batch from vertices with optional timestamp metadata.

If timestamps are not provided, they default to None (null).

pub fn build_record_batch_with_timestamps( &self, vertices: &[(Vid, Vec<String>, HashMap<String, Value>)], deleted: &[bool], versions: &[u64], schema: &Schema, created_at: Option<&HashMap<Vid, i64>>, updated_at: Option<&HashMap<Vid, i64>>, ) -> Result<RecordBatch, Error>

Build a record batch with explicit timestamp metadata.

Arguments

• vertices - Vertex ID, labels, and properties triples
• deleted - Deletion flags per vertex
• versions - Version numbers per vertex
• schema - Database schema
• created_at - Optional map of Vid -> nanoseconds since epoch
• updated_at - Optional map of Vid -> nanoseconds since epoch

pub fn get_arrow_schema(&self, schema: &Schema) -> Result<Arc<Schema>, Error>

pub async fn open_or_create( &self, backend: &(dyn StorageBackend + 'static), schema: &Schema, ) -> Result<(), Error>

Open or create a vertex table via the storage backend.

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

Write a batch to a vertex table.

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

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

Ensure default scalar indexes exist on system columns (_vid, _uid, ext_id).

pub fn table_name(&self) -> String

Get the table name for this vertex dataset.

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

Replace a vertex table’s contents atomically.

Used by compaction to rewrite the table with merged data.