Struct CountWindow 

pub struct CountWindow { /* private fields */ }

A count-based window that emits after collecting N events.

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 CountWindow

pub fn new(count: usize) -> Self

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

Add a shared event, returning completed window if count reached.

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

Add an event (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.

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

Flush all events (clones for backward compatibility).

pub const fn current_count(&self) -> usize

Get current count of events in buffer (for debugging)

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.

Trait Implementations

impl ColumnarAccess for CountWindow

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 CountWindow

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

Formats the value using the given formatter.