Struct SlidingAggr

pub struct SlidingAggr {
    pub wait: bool,
    pub op: WindowOperation,
    pub duration: Duration,
}

Represents a sliding window aggregation

The struct contains all information that is specific for a sliding window aggregation. The data that is shared between a sliding window aggregation and a discrete window aggregation is stored a Window.

Fields

wait: bool

Flag to indicate whether or not the first aggregated value will be produced immediately or whether the window waits until duration has passed at least once.

op: WindowOperation

The aggregation operation

duration: Duration

The duration of the window

The duration of a sliding window is a time span.

Trait Implementations

impl Clone for SlidingAggr

fn clone(&self) -> SlidingAggr

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SlidingAggr

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

Formats the value using the given formatter.

impl PartialEq for SlidingAggr

fn eq(&self, other: &SlidingAggr) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl WindowAggregation for SlidingAggr

fn wait_until_full(&self) -> bool

Returns wheter or not the first aggregated value will be produced immediately or wheter the window waits

fn operation(&self) -> WindowOperation

Returns the WindowOperation of the sliding or discrete window

fn duration(&self) -> Either<Duration, usize>

Returns the duration of the window

impl Copy for SlidingAggr

impl Eq for SlidingAggr

impl StructuralPartialEq for SlidingAggr