Struct AggregationCache 

pub struct AggregationCache { /* private fields */ }

Cache for precomputed aggregations

Implementations

impl AggregationCache

pub fn new() -> AggregationCache

Create a new aggregation cache

pub fn register_table(&mut self, table: &str, tracked_columns: &[&str])

Register a table for aggregation tracking

pub fn count(&self, table: &str) -> Option<u64>

Get total row count for a table

pub fn count_filtered(&self, table: &str, filter_key: &str) -> Option<u64>

Get filtered count (if cached)

pub fn set_filtered_count(&mut self, table: &str, filter_key: &str, count: u64)

Set a filtered count (precomputed)

pub fn numeric_agg(&self, table: &str, column: &str) -> Option<&NumericAgg>

Get numeric aggregation for a column

pub fn avg(&self, table: &str, column: &str) -> Option<f64>

Get average for a column

pub fn sum(&self, table: &str, column: &str) -> Option<f64>

Get sum for a column

pub fn min(&self, table: &str, column: &str) -> Option<f64>

Get min for a column

pub fn max(&self, table: &str, column: &str) -> Option<f64>

Get max for a column

pub fn distinct_count(&self, table: &str, column: &str) -> Option<u64>

Get distinct count estimate for a column

pub fn on_insert(&mut self, table: &str, values: &HashMap<String, AggValue>)

Record an insert operation

pub fn on_delete(&mut self, table: &str, values: &HashMap<String, AggValue>)

Record a delete operation

pub fn refresh<I>(&mut self, table: &str, rows: I)

where I: Iterator<Item = HashMap<String, AggValue>>,

Full refresh for a table (recompute all aggregates)

pub fn global_count(&self) -> u64

Get global row count

pub fn is_stale(&self, table: &str) -> bool

Check if aggregates are stale

pub fn stats(&self) -> AggCacheStats

Get statistics summary

Trait Implementations

impl Default for AggregationCache

fn default() -> AggregationCache

Returns the “default value” for a type.