Struct WindowedStream 

pub struct WindowedStream { /* private fields */ }

A stream with windowing applied

Implementations

impl WindowedStream

pub fn new(events: Vec<StreamEvent>, config: WindowConfig) -> Self

Create a new windowed stream

pub fn aggregate<A>(self, aggregator: A) -> Vec<AggregateResult>

where A: Aggregation,

Apply aggregation to each window

pub fn reduce<F>(self, reducer: F) -> Vec<StreamEvent>

where F: Fn(StreamEvent, StreamEvent) -> StreamEvent + Clone,

Reduce events within each window

pub fn windows(&self) -> &[TimeWindow]

Get all windows

pub fn counts(self) -> Vec<usize>

Count events in each window

pub fn flatten(self) -> DataStream

Flatten all windows back into a stream