Struct WindowedAggregation 

pub struct WindowedAggregation { /* private fields */ }

Main windowed aggregation processor.

Implementations

impl WindowedAggregation

pub fn new(config: WindowConfig) -> Self

Create a new processor with the given configuration.

pub fn process_tumbling(&self, events: &[(u64, f64)]) -> Vec<WindowResult>

Process a sequence of (timestamp_ms, value) pairs using tumbling windows.

Each event is assigned to exactly one window [start, start + size_ms).

pub fn process_sliding(&self, events: &[(u64, f64)]) -> Vec<WindowResult>

Process a sequence of (timestamp_ms, value) pairs using sliding windows.

Windows overlap: each window advances by step_ms and spans size_ms.

pub fn process_count(&self, values: &[f64]) -> Vec<WindowResult>

Process a flat slice of values using count-based windows.

Window i covers values[i*step .. i*step+size].

pub fn process_session(&self, events: &[(u64, f64)]) -> Vec<WindowResult>

Process session windows: start a new session whenever the gap between consecutive events exceeds gap_ms.

pub fn aggregate(values: &[f64], agg: WindowAggregation) -> f64

Apply an aggregation function to a slice of values.

pub fn process(&self, events: &[(u64, f64)]) -> Vec<WindowResult>

Process events using the window type specified in the configuration.