Enum WindowType 

#[non_exhaustive]
pub enum WindowType {
    Tumbling {
        size_ms: u64,
    },
    Sliding {
        size_ms: u64,
        step_ms: u64,
    },
    Session {
        gap_ms: u64,
    },
}

Strategy for partitioning an event-time stream into windows.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Tumbling

Fixed-size non-overlapping window.

Fields

size_ms: u64

Window duration in milliseconds.

Sliding

Overlapping window.

Fields

size_ms: u64

Window duration in milliseconds.

step_ms: u64

Distance between successive window starts in milliseconds.

Session

Session window — a burst of activity separated by idle gaps.

Fields

gap_ms: u64

Maximum inactivity gap in milliseconds before closing a session.

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.