Struct SimdBatchProcessor 

pub struct SimdBatchProcessor { /* private fields */ }

SIMD-accelerated batch processor

Implementations

impl SimdBatchProcessor

pub fn new(config: SimdBatchConfig) -> Self

Create a new SIMD batch processor

pub fn process_batch<F>( &mut self, events: &[StreamEvent], processor: F, ) -> Result<Vec<StreamEvent>>

where F: Fn(&StreamEvent) -> bool + Send + Sync,

Process a batch of events with SIMD acceleration

pub fn extract_numeric_batch( &self, events: &[StreamEvent], field: &str, ) -> Result<Array1<f64>>

Extract numeric fields from events with SIMD acceleration

pub fn aggregate_batch( &mut self, events: &[StreamEvent], field: &str, ) -> Result<SimdAggregateResult>

Compute batch aggregations with SIMD

pub fn batch_pattern_match( &mut self, events: &[StreamEvent], patterns: &[String], ) -> Result<Vec<(usize, String)>>

Vectorized pattern matching across batch

pub fn correlation_matrix( &mut self, events: &[StreamEvent], fields: &[String], ) -> Result<Array2<f64>>

Compute correlation matrix for multiple fields with SIMD

pub fn deduplicate_batch( &mut self, events: &[StreamEvent], ) -> Result<Vec<StreamEvent>>

Batch deduplication with SIMD hash comparison

pub fn moving_average( &mut self, events: &[StreamEvent], field: &str, window_size: usize, ) -> Result<Array1<f64>>

SIMD-accelerated moving average computation

pub fn stats(&self) -> &SimdProcessorStats

Get processor statistics

pub fn reset_stats(&mut self)

Reset statistics