Enum WindowType 

pub enum WindowType {
    Tumbling(Duration),
    Sliding(Duration, Duration),
    Session(Duration),
    Global,
}

Window type for stream processing

Variants

Tumbling(Duration)

Tumbling window with fixed size

Sliding(Duration, Duration)

Sliding window with size and slide interval

Session(Duration)

Session window with gap timeout

Global

Global window, no window boundaries

Implementations

impl WindowType

pub fn get_affected_windows(&self, timestamp: i64) -> Vec<i64>

pub fn get_window_keys(&self, timestamp: i64) -> Vec<u64>

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.