Struct WindowConfig 

pub struct WindowConfig {
    pub window_type: WindowType,
    pub allow_lateness: Duration,
    pub watermark_delay: Duration,
}

Configuration for windowed operations

Fields

window_type: WindowType

Type of the window

allow_lateness: Duration

Whether to allow late arrivals

watermark_delay: Duration

Watermark strategy (time to wait before processing)

Implementations

impl WindowConfig

pub fn tumbling(size: Duration) -> Self

Create a new tumbling window configuration

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

Create a new sliding window configuration

pub fn session(gap: Duration) -> Self

Create a new session window configuration

pub fn global() -> Self

Create a new global window configuration

pub fn with_lateness(self, lateness: Duration) -> Self

Set the allowed lateness for this window

pub fn with_watermark_delay(self, delay: Duration) -> Self

Set the watermark delay for this window

Trait Implementations

impl Clone for WindowConfig

fn clone(&self) -> WindowConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WindowConfig

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

Formats the value using the given formatter.