Struct TumblingWindowAssigner 

pub struct TumblingWindowAssigner { /* private fields */ }

Tumbling window assigner.

Assigns each event to exactly one non-overlapping window based on its timestamp. Windows are aligned to epoch (timestamp 0).

Implementations

impl TumblingWindowAssigner

pub fn new(size: Duration) -> Self

Creates a new tumbling window assigner.

Arguments

• size - The duration of each window

Panics

Panics if the size is zero.

pub fn from_millis(size_ms: i64) -> Self

Creates a new tumbling window assigner with size in milliseconds.

Panics

Panics if the size is zero or negative.

pub fn with_offset_ms(self, offset_ms: i64) -> Self

Set window offset in milliseconds.

pub fn size_ms(&self) -> i64

Returns the window size in milliseconds.

pub fn offset_ms(&self) -> i64

Returns the window offset in milliseconds.

pub fn assign(&self, timestamp: i64) -> WindowId

Assigns a timestamp to a window.

This is the core window assignment function with O(1) complexity. When an offset is set, windows are shifted: floor((ts - offset) / size) * size + 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: i64) -> WindowIdVec

Assigns an event timestamp to zero or more windows.

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

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