Struct RollingEngine 

pub struct RollingEngine<G, S: Slot, Accumulator> { /* private fields */ }

Implementations

impl<G, S, Accumulator> RollingEngine<G, S, Accumulator>

where G: Clone + Eq + Ord + Hash + Debug + StateCodec, S: Slot + Hash + HeapSize, Accumulator: WindowAccumulator, GroupMeta<S>: OperatorState, RollingIndexEntry<G>: OperatorState, RollingBuffer<S, Accumulator>: OperatorState,

pub fn new(config: WindowEngineConfig) -> Self

pub fn new_runnable(config: WindowEngineConfig) -> Self

pub fn with_lag(self, lag: <S::Coord as Coord>::Span) -> Self

pub fn apply<K, CB, Output>( &mut self, store: &mut dyn StateStore, buckets: RollingBuckets<G, S, Accumulator::Contribution>, capacity: usize, row_key: K, combine: CB, ) -> Result<Vec<RollingResult<G, Output>>>

where K: Fn(&G) -> (GroupId, EncodedKey), CB: Fn(&G, &RollingBuffer<S, Accumulator>) -> Option<Output>,

pub fn apply_evicting<K, NA, CB, Output>( &mut self, store: &mut dyn StateStore, buckets: RollingBuckets<G, S, Accumulator::Contribution>, eviction: RollingEviction<S>, row_key: K, new_accumulator: NA, combine: CB, ) -> Result<Vec<RollingResult<G, Output>>>

where K: Fn(&G) -> (GroupId, EncodedKey), NA: Fn() -> Accumulator, CB: Fn(&G, &RollingBuffer<S, Accumulator>) -> Option<Output>,

pub fn apply_running<K, NA>( &mut self, store: &mut dyn StateStore, buckets: RollingBuckets<G, S, Accumulator::Contribution>, eviction: RollingEviction<S>, row_key: K, new_accumulator: NA, ) -> Result<Vec<RollingResult<G, Accumulator::Output>>>

where K: Fn(&G) -> (GroupId, EncodedKey), NA: Fn() -> Accumulator,

pub fn expire_before_running( &mut self, store: &mut dyn StateStore, cutoff: S, ) -> Result<Vec<RollingExpiry<G, Accumulator::Output>>>

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

pub fn earliest_expiry( &mut self, store: &mut dyn StateStore, ) -> Result<Option<u64>>

pub fn expire_before<CB, Output>( &mut self, store: &mut dyn StateStore, cutoff: S, combine: CB, ) -> Result<Vec<RollingExpiry<G, Output>>>

where CB: Fn(&G, &RollingBuffer<S, Accumulator>) -> Option<Output>,