Struct TumblingWindowAssigner 

pub struct TumblingWindowAssigner { /* private fields */ }

Tumbling window assigner

Creates fixed-size, non-overlapping windows. Each event is assigned to exactly one window based on its timestamp.

Example

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

Implementations

impl TumblingWindowAssigner

pub fn new(size: Duration) -> Self

Create a new tumbling window assigner

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

Create a tumbling window assigner with an offset

Trait Implementations

impl Clone for TumblingWindowAssigner

fn clone(&self) -> TumblingWindowAssigner

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TumblingWindowAssigner

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

Formats the value using the given formatter.

impl WindowAssigner for TumblingWindowAssigner

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)