Struct TumblingWindow 

pub struct TumblingWindow { /* private fields */ }

A tumbling window that collects events over a fixed duration.

Supports both row-oriented and columnar access patterns:

• flush_shared(): Row-oriented access for backward compatibility
• flush_columnar(): Columnar access for SIMD-optimized aggregations

Implementations

impl TumblingWindow

pub fn new(duration: Duration) -> Self

pub fn add_shared(&mut self, event: SharedEvent) -> Option<Vec<SharedEvent>>

Add a shared event to the window, returning completed window if triggered.

pub fn add(&mut self, event: Event) -> Option<Vec<Event>>

Add an event to the window (wraps in Arc).

pub fn flush_shared(&mut self) -> Vec<SharedEvent>

Flush all events as SharedEvent references.

pub fn flush_columnar(&mut self) -> ColumnarBuffer

Flush and return the columnar buffer for SIMD-optimized aggregations.

The returned buffer can be used with Aggregator::apply_columnar().

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

Flush all events (clones for backward compatibility).

pub const fn len(&self) -> usize

Get the number of events currently in the window.

pub const fn is_empty(&self) -> bool

Check if the window is empty.

pub fn checkpoint(&self) -> WindowCheckpoint

Create a checkpoint of the current window state.

pub fn restore(&mut self, cp: &WindowCheckpoint)

Restore window state from a checkpoint.

pub fn advance_watermark( &mut self, wm: DateTime<Utc>, ) -> Option<Vec<SharedEvent>>

Advance watermark — close window if watermark passes window end.

Trait Implementations

impl ColumnarAccess for TumblingWindow

fn columnar(&self) -> &ColumnarBuffer

Get a reference to the columnar buffer.

fn columnar_mut(&mut self) -> &mut ColumnarBuffer

Get a mutable reference to the columnar buffer.

fn get_float_column(&mut self, field: &str) -> &[f64]

Get a float column, ensuring it exists.

fn get_int_column(&mut self, field: &str) -> &[i64]

Get an int column, ensuring it exists.

fn get_string_column(&mut self, field: &str) -> &[Option<Arc<str>>]

Get a string column, ensuring it exists.

impl Debug for TumblingWindow

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

Formats the value using the given formatter.