Struct SessionWindow 

pub struct SessionWindow { /* private fields */ }

A session window that groups events separated by gaps of inactivity.

Events are accumulated into a session. When a new event arrives after a gap exceeding the configured duration, the current session is closed (emitted) and a new session begins with the incoming event.

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 SessionWindow

pub fn new(gap: Duration) -> Self

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

Add a shared event to the session window. Returns the completed session if the gap was exceeded.

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

Add an event (wraps in Arc).

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

Check if this session has expired (last event time + gap < now). Returns accumulated events if expired, None otherwise.

pub const fn gap(&self) -> Duration

Get the configured gap duration.

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 fn checkpoint(&self) -> WindowCheckpoint

Create a checkpoint of the current session state.

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

Restore session state from a checkpoint.

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

Advance watermark — close session if watermark exceeds last_event_time + gap.

Trait Implementations

impl ColumnarAccess for SessionWindow

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 SessionWindow

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

Formats the value using the given formatter.