Struct rtlola_hir::hir::DiscreteAggr

pub struct DiscreteAggr {
    pub wait: bool,
    pub op: WindowOperation,
    pub duration: usize,
}

Represents a discrete window aggregation

The struct contains all information that is specific for a discrete 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: usize

The duration of the window

The duration of a discrete window is a discrete number of values.

Trait Implementations

impl Clone for DiscreteAggr

fn clone(&self) -> DiscreteAggr

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for DiscreteAggr

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

Formats the value using the given formatter.

impl PartialEq<DiscreteAggr> for DiscreteAggr

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

impl WindowAggregation for DiscreteAggr

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 DiscreteAggr

impl StructuralPartialEq for DiscreteAggr