Struct SlidingWindowAssigner 

pub struct SlidingWindowAssigner { /* private fields */ }

Sliding window assigner

Creates fixed-size, overlapping windows. Each event may be assigned to multiple windows based on the slide interval.

Example

Window size: 10 seconds, Slide: 5 seconds
Event at timestamp 7 -> Windows [0, 10), [5, 15)
Event at timestamp 12 -> Windows [5, 15), [10, 20)

Implementations

impl SlidingWindowAssigner

pub fn new(size: Duration, slide: Duration) -> Self

Create a new sliding window assigner

pub fn with_offset(self, offset: Duration) -> Self

Create a sliding window assigner with an offset

Trait Implementations

impl Clone for SlidingWindowAssigner

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 SlidingWindowAssigner

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

Formats the value using the given formatter.

impl WindowAssigner for SlidingWindowAssigner

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

Assign a timestamp to one or more windows

fn max_windows_per_event(&self) -> usize

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

fn is_session_window(&self) -> bool

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