Struct RollingIncrementalEngine 

pub struct RollingIncrementalEngine<G, C, Accumulator, Running> { /* private fields */ }

Implementations

impl<G, C, Accumulator, Running> RollingIncrementalEngine<G, C, Accumulator, Running>

where G: Clone + Eq + Ord + Hash + Debug, C: Slot + Hash + HeapSize, Accumulator: WindowAccumulator, Running: WindowAccumulator, for<'a> &'a G: IntoEncodedKey, GroupMeta<C>: OperatorState, RollingBuffer<C, Accumulator>: OperatorState + HeapSize,

pub fn new(_config: WindowEngineConfig) -> Self

pub fn expire_meta( &mut self, store: &mut dyn StateStore, threshold: u64, ) -> Result<usize>

pub fn apply<K, WC, CR, Output>( &mut self, store: &mut dyn StateStore, buckets: RollingBuckets<G, C, Accumulator::Contribution>, capacity: usize, row_key: K, window_contribution: WC, combine_running: CR, ) -> Result<Vec<RollingResult<G, Output>>>

where K: Fn(&G) -> EncodedKey, WC: Fn(&Accumulator::Output) -> Running::Contribution, CR: Fn(&G, &Running, &Accumulator::Output, C) -> Option<Output>,