Struct IncrementalAlgorithmProcessor

pub struct IncrementalAlgorithmProcessor { /* private fields */ }

Incremental algorithm processor for streaming updates

Implementations

impl IncrementalAlgorithmProcessor

pub fn new() -> Self

Create a new incremental algorithm processor

pub fn set_invalidation_threshold(&mut self, threshold: u64)

Set the cache invalidation threshold

pub fn is_cache_valid( &self, algorithm_name: &str, current_update_count: u64, ) -> bool

Check if cached result is still valid

pub fn cache_result( &mut self, algorithm_name: String, update_count: u64, result: RecordBatch, )

Cache algorithm result

pub fn get_cached_result( &self, algorithm_name: &str, current_update_count: u64, ) -> Option<RecordBatch>

Get cached result if valid

pub fn invalidate_cache(&mut self, algorithm_name: &str)

Invalidate cache for specific algorithm

pub fn clear_cache(&mut self)

Clear all cached results

pub fn get_cache_statistics(&self) -> CacheStatistics

Get cache statistics

Trait Implementations

impl Default for IncrementalAlgorithmProcessor

fn default() -> Self

Returns the “default value” for a type.