Struct StatisticsManager 

pub struct StatisticsManager { /* private fields */ }

Statistical Information Manager

Centralized management of all statistical information, ensuring thread-safe access. All statistics are scoped to a space; keys are "{space}.{name}" composite keys.

Implementations

impl StatisticsManager

pub fn new() -> Self

Create a new statistical information manager.

pub fn mark_space_dirty(&self, space: &str)

Mark the statistics for space as stale (forces re-collection).

pub fn invalidate_space(&self, space: Option<&str>)

Invalidate statistics for a space (None = all spaces).

pub fn space_stamp(&self, space: &str) -> Option<(u64, u64)>

The composite (schema_version, data_epoch) stamp for space, if statistics have been collected for it.

pub fn space_version(&self, space: &str) -> Option<u64>

The schema version recorded for space at its last collection, if any.

pub fn set_space_stamp(&self, space: &str, schema_version: u64, data_epoch: u64)

Record the composite stamp at which space was last collected. Unknown versions (0) are never cached: a zero schema or data version means cacheability is unknown, so the stamp is not stored and the next collection always re-samples.

pub fn register_tag_indexes( &self, space: &str, tag_name: &str, tag_id: i32, indexes: Vec<Index>, )

Register the available indexes for tag_name in space.

Called by the query pipeline when it builds the planning metadata context; registration overwrites any previously registered catalog for the tag, so schema changes are picked up on the next query.

pub fn get_tag_indexes( &self, space: &str, tag_name: &str, ) -> Option<(i32, Vec<Index>)>

The available indexes for tag_name in space, with the tag id.

pub fn register_tag_id(&self, space: &str, tag_id: i32, tag_name: String)

Mapping of registered tag IDs to their corresponding names.

Scoped by space ("{space}:{id}") so tag ids reused across spaces cannot overwrite each other.

pub fn get_tag_name_by_id(&self, space: &str, tag_id: i32) -> Option<String>

Retrieve the tag name for a tag ID in a specific space.

pub fn get_tag_stats_by_id( &self, space: &str, tag_id: i32, ) -> Option<TagStatistics>

Retrieve tag statistics based on the tag ID in a specific space.

pub fn get_vertex_count_by_id(&self, space: &str, tag_id: i32) -> u64

Get the number of vertices based on the tag ID in a specific space.

pub fn get_tag_stats( &self, space: &str, tag_name: &str, ) -> Option<TagStatistics>

Obtain tag statistics information for a specific space.

pub fn update_tag_stats(&self, space: &str, stats: TagStatistics)

Update the tag statistics information for a specific space.

pub fn get_vertex_count(&self, space: &str, tag_name: &str) -> u64

Obtain the number of vertices for a specific space.

pub fn get_edge_stats( &self, space: &str, edge_type: &str, ) -> Option<EdgeTypeStatistics>

Obtain statistical information about the types of edges for a specific space.

pub fn update_edge_stats(&self, space: &str, stats: EdgeTypeStatistics)

Update the statistics information on edge types for a specific space.

pub fn get_edge_count(&self, space: &str, edge_type: &str) -> u64

Obtain the number of edges for a specific space.

pub fn get_property_stats( &self, space: &str, tag_name: Option<&str>, property_name: &str, ) -> Option<PropertyStatistics>

Obtain attribute statistics information for a specific space.

pub fn update_property_stats(&self, space: &str, stats: PropertyStatistics)

Update attribute statistics information for a specific space.

pub fn clear_all(&self)

Clear all statistical information.

pub fn get_property_combo_stats( &self, space: &str, tag_name: &str, properties: &[String], ) -> Option<PropertyCombinationStats>

Get property combination statistics for GROUP BY cardinality estimation.

pub fn update_property_combo_stats( &self, space: &str, stats: PropertyCombinationStats, )

Update property combination statistics for a specific space. Existing entries merge via exponential moving average so repeated collections refine rather than replace the estimate.

pub fn get_combined_cardinality( &self, space: &str, tag_name: Option<&str>, properties: &[String], ) -> Option<u64>

Get combined cardinality for a set of properties. Returns None if no statistics are available.

pub fn get_all_tags(&self) -> Vec<String>

Retrieve all tag names.

Returns bare tag names; space-qualified entries are de-duplicated.

pub fn get_all_edge_types(&self) -> Vec<String>

Obtain the names of all edge types (space-qualified entries de-duplicated).

Trait Implementations

impl Clone for StatisticsManager

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StatisticsManager

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

Formats the value using the given formatter.

impl Default for StatisticsManager

fn default() -> Self

Returns the “default value” for a type.