Struct Aggregator 

pub struct Aggregator { /* private fields */ }

Aggregator that can apply multiple aggregations

Implementations

impl Aggregator

pub fn new() -> Self

pub fn add( self, alias: impl Into<String>, func: Box<dyn AggregateFunc>, field: Option<String>, ) -> Self

pub fn apply(&self, events: &[Event]) -> AggResult

pub fn apply_shared(&self, events: &[SharedEvent]) -> AggResult

Apply aggregations to SharedEvent slice (avoids cloning in hot paths)

pub fn apply_columnar(&self, buffer: &mut ColumnarBuffer) -> AggResult

Apply aggregations to a columnar buffer (SIMD-optimized).

This method uses lazy column extraction for SIMD operations on contiguous memory. Each field is extracted once and cached for subsequent aggregations on the same field.

Example

let aggregator = Aggregator::new()
    .add("total", Box::new(Sum), Some("price".to_string()))
    .add("avg_price", Box::new(Avg), Some("price".to_string()))
    .add("count", Box::new(Count), None);

let mut window = TumblingWindow::new(Duration::seconds(60));
// ... add events ...
let mut buffer = window.flush_columnar();
let results = aggregator.apply_columnar(&mut buffer);

Trait Implementations

impl Debug for Aggregator

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

Formats the value using the given formatter.

impl Default for Aggregator

fn default() -> Self

Returns the “default value” for a type.