Struct WindowConfig 

pub struct WindowConfig {
    pub window_type: WindowType,
    pub aggregation: WindowAggregation,
    pub emit_partial: bool,
    pub min_elements: usize,
}

Configuration for windowed aggregation.

Fields

window_type: WindowType

Window type (Tumbling, Sliding, Session, or Count).

aggregation: WindowAggregation

Aggregation function to apply within each window.

emit_partial: bool

Emit a partial result for windows that do not span a complete interval.

min_elements: usize

Minimum number of elements required before a window result is emitted.

Implementations

impl WindowConfig

pub fn tumbling(size_ms: u64, aggregation: WindowAggregation) -> Self

Create a tumbling window configuration.

pub fn sliding( size_ms: u64, step_ms: u64, aggregation: WindowAggregation, ) -> Self

Create a sliding window configuration.

pub fn count(size: usize, step: usize, aggregation: WindowAggregation) -> Self

Create a count-based window configuration.

pub fn with_emit_partial(self, emit: bool) -> Self

Set whether partial (incomplete) windows should be emitted.

pub fn with_min_elements(self, min: usize) -> Self

Set the minimum number of elements required to emit a 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.