Trait rtlola_hir::hir::WindowAggregation

source · 
pub trait WindowAggregation: Debug + Copy {
    fn wait_until_full(&self) -> bool;
    fn operation(&self) -> WindowOperation;
    fn duration(&self) -> Either<Duration, usize>;
}
Expand description

Functionality of sliding window and discrete window aggregations

Required Methods§

source

fn wait_until_full(&self) -> bool

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

The function returns true if the windows waits until the Duration has passed at least once. Otherwise the function returns false.

source

fn operation(&self) -> WindowOperation

Returns the WindowOperation of the sliding or discrete window

source

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

Returns the duration of the window

The function returns the duration of a sliding window or the number of values used for a discrete window.

Implementors§