Struct WindowManager 

pub struct WindowManager { /* private fields */ }

Generic window manager for streaming aggregations

Implementations

impl WindowManager

pub fn new(window_type: WindowType) -> Self

Create a new window manager

pub fn aggregate( &mut self, field: &str, function: AggregateFunction, output_name: &str, ) -> &mut Self

Add an aggregation specification

pub fn process( &mut self, timestamp: DateTime<Utc>, fields: HashMap<String, KindedSlot>, ) -> Result<()>

Process a data point

pub fn take_completed(&mut self) -> Vec<WindowResult>

Take completed windows

pub fn flush(&mut self) -> Result<Vec<WindowResult>>

Flush any remaining windows (call at end of stream)