Struct WindowMerger 

pub struct WindowMerger { /* private fields */ }

Window merger for session windows

Handles merging of session windows when events arrive within the session gap.

Implementations

impl WindowMerger

pub fn new(session_gap: Duration) -> Self

Create a new window merger with the specified session gap

pub fn add_and_merge(&mut self, window: Window) -> (Window, Vec<Window>)

Add a window and merge with overlapping/nearby windows

Returns the final merged window and a list of windows that were merged

pub fn windows(&self) -> Vec<&Window>

Get all active windows

pub fn remove(&mut self, window_id: &str) -> Option<Window>

Remove a window by ID

pub fn remove_old_windows(&mut self, watermark: DateTime<Utc>) -> Vec<Window>

Remove windows older than the given watermark

pub fn clear(&mut self)

Clear all windows

Trait Implementations

impl Debug for WindowMerger

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

Formats the value using the given formatter.