Struct PropertyManager 

pub struct PropertyManager { /* private fields */ }

Implementations

impl PropertyManager

pub fn new( storage: Arc<StorageManager>, schema_manager: Arc<SchemaManager>, capacity: usize, ) -> Self

pub fn cache_size(&self) -> usize

pub fn caching_enabled(&self) -> bool

Check if caching is enabled

pub async fn clear_cache(&self)

Clear all caches. Call this when L0 is rotated, flushed, or compaction occurs to prevent stale reads.

pub async fn invalidate_vertex(&self, _vid: Vid)

Invalidate a specific vertex’s cached properties.

pub async fn invalidate_edge(&self, _eid: Eid)

Invalidate a specific edge’s cached properties.

pub async fn get_edge_prop( &self, eid: Eid, prop: &str, ctx: Option<&QueryContext>, ) -> Result<Value>

pub async fn get_all_edge_props_with_ctx( &self, eid: Eid, ctx: Option<&QueryContext>, ) -> Result<Option<Properties>>

pub async fn get_batch_vertex_props( &self, vids: &[Vid], properties: &[&str], ctx: Option<&QueryContext>, ) -> Result<HashMap<Vid, Properties>>

Batch load properties for multiple vertices

pub async fn get_batch_edge_props( &self, eids: &[Eid], properties: &[&str], ctx: Option<&QueryContext>, ) -> Result<HashMap<Vid, Properties>>

Load properties as Arrow columns for vectorized processing Batch load properties for multiple edges

pub async fn load_properties_columnar( &self, vids: &UInt64Array, properties: &[&str], ctx: Option<&QueryContext>, ) -> Result<RecordBatch>

pub async fn get_batch_labels( &self, vids: &[Vid], ctx: Option<&QueryContext>, ) -> Result<HashMap<Vid, Vec<String>>>

Batch load labels for multiple vertices.

pub async fn get_all_vertex_props(&self, vid: Vid) -> Result<Properties>

pub async fn get_all_vertex_props_with_ctx( &self, vid: Vid, ctx: Option<&QueryContext>, ) -> Result<Option<Properties>>

pub async fn get_batch_vertex_props_for_label( &self, vids: &[Vid], label: &str, ctx: Option<&QueryContext>, ) -> Result<HashMap<Vid, Properties>>

Batch-fetch properties for multiple vertices of a known label.

Queries L0 layers in-memory, then fetches remaining VIDs from LanceDB in a single _vid IN (...) query on the label table. Much faster than per-vertex get_all_vertex_props_with_ctx when many vertices need loading.

pub async fn get_vertex_prop(&self, vid: Vid, prop: &str) -> Result<Value>

pub async fn get_vertex_prop_with_ctx( &self, vid: Vid, prop: &str, ctx: Option<&QueryContext>, ) -> Result<Value>

pub fn value_from_column( col: &dyn Array, data_type: &DataType, row: usize, ) -> Result<Value>

Decode an Arrow column value with strict CRDT error handling.