Struct WindowManager 

pub struct WindowManager<A, T>
where
    A: WindowAssigner,
    T: WindowTrigger,
{ /* private fields */ }

Manager for window lifecycles

The WindowManager coordinates all aspects of window management:

• Assigns events to appropriate windows
• Tracks active windows and their states
• Evaluates triggers to determine when windows should fire
• Handles window merging for session windows
• Cleans up completed windows

Implementations

impl<A, T> WindowManager<A, T>

where A: WindowAssigner, T: WindowTrigger,

pub fn new(assigner: A, trigger: T) -> Self

Create a new window manager

pub fn with_late_events( assigner: A, trigger: T, allow_late_events: bool, late_event_threshold: Duration, ) -> Self

Create a window manager with custom late event handling

pub fn assign_event( &mut self, event_time: DateTime<Utc>, ) -> Result<Vec<Window>, ProcessorError>

Assign an event to windows and update window metadata

Returns the list of windows that this event belongs to.

pub fn advance_watermark( &mut self, watermark: DateTime<Utc>, ) -> Result<Vec<String>, ProcessorError>

Update the watermark and check which windows are ready to fire

Returns a list of window IDs that should be evaluated.

pub fn get_window(&self, window_id: &str) -> Option<WindowMetadata>

Get metadata for a specific window

pub fn remove_window(&mut self, window_id: &str) -> Option<WindowMetadata>

Remove and return a window (for cleanup after processing)

pub fn active_window_ids(&self) -> Vec<String>

Get all active window IDs

pub fn active_window_count(&self) -> usize

Get the number of active windows

pub fn current_watermark(&self) -> Option<DateTime<Utc>>

Get the current watermark

pub fn cleanup_old_windows(&mut self, retention_duration: Duration) -> usize

Clean up old windows that have been triggered and are beyond retention

Returns the number of windows removed.

pub fn get_statistics(&self) -> HashMap<String, WindowStats>

Get statistics for all active windows

pub fn reset(&mut self)

Reset the manager (clear all windows)