Skip to main content

AggregationWindowingExt

netgauze_analytics::aggregation

Trait AggregationWindowingExt 

Source 
pub trait AggregationWindowingExt<Key: Eq + Hash + Clone, Input: TimeSeriesData<Key>, AggInit: Clone, AggValue, AggregatorImpl: Aggregator<AggInit, Input, AggValue>>: Iterator<Item = Input> + Sized {
    // Provided method
    fn window_aggregate(
        self,
        window_duration: Duration,
        lateness: Duration,
        agg_init: AggInit,
        agg_fn: AggregatorImpl,
    ) -> WindowedAggregationAdaptor<Key, Input, AggInit, AggValue, AggregatorImpl, Self> ⓘ { ... }
}

Provided Methods§

Source

fn window_aggregate( self, window_duration: Duration, lateness: Duration, agg_init: AggInit, agg_fn: AggregatorImpl, ) -> WindowedAggregationAdaptor<Key, Input, AggInit, AggValue, AggregatorImpl, Self> ⓘ

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§

Source§

impl<Key: Eq + Hash + Clone, Input: TimeSeriesData<Key>, AggInit: Clone, AggValue, AggregatorImpl: Aggregator<AggInit, Input, AggValue>, I: Iterator<Item = Input>> AggregationWindowingExt<Key, Input, AggInit, AggValue, AggregatorImpl> for I