Enum WindowingStrategy 

pub enum WindowingStrategy {
    Sliding {
        size: usize,
    },
    Tumbling {
        size: usize,
    },
    Session {
        timeout: Duration,
    },
    TimeBased {
        duration: Duration,
    },
    Adaptive {
        minsize: usize,
        maxsize: usize,
        adaptation_rate: f64,
    },
    EventDriven {
        trigger_condition: String,
    },
}

Windowing strategies for streaming data

Variants

Sliding

Fixed-size sliding window

Fields

size: usize

Tumbling

Tumbling window (non-overlapping)

Fields

size: usize

Session

Session-based windowing

Fields

timeout: Duration

TimeBased

Time-based windowing

Fields

duration: Duration

Adaptive

Adaptive windowing based on data characteristics

Fields

minsize: usize

maxsize: usize

adaptation_rate: f64

EventDriven

Event-driven windowing

Fields

trigger_condition: String

Trait Implementations

impl Clone for WindowingStrategy

fn clone(&self) -> WindowingStrategy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WindowingStrategy

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WindowingStrategy

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WindowingStrategy

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.