Enum WindowType 

pub enum WindowType {
    Tumbling {
        size: Duration,
    },
    Sliding {
        size: Duration,
        slide: Duration,
    },
    Session {
        gap: Duration,
    },
    Count {
        size: usize,
    },
    Cumulative,
}

Window type for aggregations

Variants

Tumbling

Fixed non-overlapping windows

Fields

size: Duration

Sliding

Overlapping windows with a slide interval

Fields

size: Duration

slide: Duration

Session

Windows based on inactivity gaps

Fields

gap: Duration

Count

Count-based windows (every N records)

Fields

size: usize

Cumulative

Cumulative from start

Implementations

impl WindowType

pub fn tumbling(size: Duration) -> Self

Create a tumbling window

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

Create a sliding window

pub fn session(gap: Duration) -> Self

Create a session window

pub fn count(size: usize) -> Self

Create a count-based window

pub fn cumulative() -> Self

Create a cumulative window

Trait Implementations

impl Clone for WindowType

fn clone(&self) -> WindowType

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WindowType

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

Formats the value using the given formatter.