Struct SlidingWindowAssigner 

pub struct SlidingWindowAssigner { /* private fields */ }

Sliding window assigner.

Assigns each event to multiple overlapping windows based on its timestamp. Windows are aligned to epoch (timestamp 0).

Parameters

• size_ms: The duration of each window in milliseconds
• slide_ms: The advance interval between windows in milliseconds

Window Assignment

An event at timestamp t belongs to all windows [start, start + size) where start <= t < start + size and start is a multiple of slide.

The number of windows per event is ceil(size / slide).

Example

use laminar_core::operator::sliding_window::SlidingWindowAssigner;
use std::time::Duration;

// 1-minute window with 20-second slide
let assigner = SlidingWindowAssigner::new(
    Duration::from_secs(60),
    Duration::from_secs(20),
);

// Event at t=50 belongs to windows: [0,60), [20,80), [40,100)

Implementations

impl SlidingWindowAssigner

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

Creates a new sliding window assigner.

Arguments

• size - The duration of each window
• slide - The advance interval between windows

Panics

Panics if:

• Size is zero or negative
• Slide is zero or negative
• Slide is greater than size (use tumbling windows instead)

pub fn from_millis(size_ms: i64, slide_ms: i64) -> Self

Creates a new sliding window assigner with sizes in milliseconds.

Panics

Panics if size or slide is zero/negative, or if slide > size.

pub fn size_ms(&self) -> i64

Returns the window size in milliseconds.

pub fn slide_ms(&self) -> i64

Returns the slide interval in milliseconds.

pub fn windows_per_event(&self) -> usize

Returns the number of windows each event belongs to.

Trait Implementations

impl Clone for SlidingWindowAssigner

fn clone(&self) -> SlidingWindowAssigner

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: i64) -> WindowIdVec

Assigns a timestamp to all overlapping windows.

Returns windows in order from earliest to latest start time.

fn max_timestamp(&self, window_end: i64) -> i64

Returns the maximum timestamp that could still be assigned to a window ending at window_end.