Struct SessionWindowAssigner 

pub struct SessionWindowAssigner { /* private fields */ }

Session window assigner

Creates variable-size windows based on inactivity gaps. Events are grouped into the same window if they occur within the session gap of each other. Session windows require merging when new events arrive.

Example

Session gap: 5 seconds
Events at 0, 2, 10 -> Windows [0, 7), [10, 15)
Event at 4 arrives -> Windows merge to [0, 9), [10, 15)

Implementations

impl SessionWindowAssigner

pub fn new(gap: Duration) -> Self

Create a new session window assigner

pub fn gap(&self) -> Duration

Get the session gap

Trait Implementations

impl Clone for SessionWindowAssigner

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SessionWindowAssigner

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

Formats the value using the given formatter.

impl WindowAssigner for SessionWindowAssigner

fn assign_windows(&self, timestamp: DateTime<Utc>) -> Vec<Window>

Assign a timestamp to one or more windows

fn is_session_window(&self) -> bool

Check if this is a session window assigner (requires merging)

fn max_windows_per_event(&self) -> usize

Get the maximum number of windows an event can be assigned to