Struct WindowAlgebra 

pub struct WindowAlgebra<T: Clone> { /* private fields */ }

The main stream windowing algebra operator.

Generic over the event payload type T.

Implementations

impl<T: Clone> WindowAlgebra<T>

pub fn new(config: WindowAlgebraConfig) -> Self

Create a new windowing operator with the given configuration.

pub fn tumbling(size: Duration) -> Self

Create a tumbling window operator.

pub fn sliding(size: Duration, slide: Duration) -> Self

Create a sliding window operator.

pub fn session(gap: Duration) -> Self

Create a session window operator.

pub fn count(count: usize) -> Self

Create a count-based window operator.

pub fn with_late_policy(self, policy: LatePolicy) -> Self

Set the late data policy.

pub fn with_max_open_windows(self, max: usize) -> Self

Set the maximum number of open windows.

pub fn stats(&self) -> &WindowAlgebraStats

Get current statistics.

pub fn watermark_ms(&self) -> i64

Get current watermark in milliseconds.

pub fn open_pane_count(&self) -> usize

Get the number of currently open panes.

pub fn drain_side_output(&mut self) -> Vec<WindowEvent<T>>

Get the side output (late events).

pub fn advance_watermark(&mut self, watermark_ms: i64) -> Vec<WindowOutput<T>>

Advance the watermark and return any windows that should be closed.

pub fn ingest(&mut self, event: WindowEvent<T>) -> Vec<WindowOutput<T>>

Ingest a single event. Returns any triggered window outputs.

pub fn ingest_batch( &mut self, events: Vec<WindowEvent<T>>, ) -> Vec<WindowOutput<T>>

Ingest a batch of events.

pub fn flush(&mut self) -> Vec<WindowOutput<T>>

Flush all open windows, emitting their contents.

pub fn aggregate<A, F>( &self, window_id: &WindowId, init: A, fold: F, ) -> Option<A>

where F: Fn(A, &T) -> A,

Aggregate window contents using a fold function.