Struct TumblingEngine 

pub struct TumblingEngine<G, S, Accumulator> { /* private fields */ }

Implementations

impl<G, S, Accumulator> TumblingEngine<G, S, Accumulator>

where G: Clone + Eq + Ord + Hash + Debug + StateCodec, S: WindowAnchor + Hash, Accumulator: WindowAccumulator, GroupMeta<S>: OperatorState, TumblingIndexEntry<G, S>: OperatorState,

pub fn new(config: WindowEngineConfig) -> Self

pub fn dropped_retractions(&self) -> u64

pub fn reindex_window( &mut self, store: &mut dyn StateStore, group: &G, window_start: S, id: GroupId, slot_key: &EncodedKey, prior: Option<u64>, new: Option<u64>, ) -> Result<()>

pub fn apply<K, NA>( &mut self, store: &mut dyn StateStore, buckets: TumblingBuckets<G, S, Accumulator::Contribution>, order: &[(G, WindowSpan<S>)], slot_key: K, new_accumulator: NA, ) -> Result<Vec<WindowResult<G, S, Accumulator::Output>>>

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

pub fn expire( &mut self, store: &mut dyn StateStore, threshold: u64, ) -> Result<Vec<ExpiredWindow<G, S>>>

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

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

Trait Implementations

impl<G, S, Accumulator> Reaper for TumblingEngine<G, S, Accumulator>

where S: WindowAnchor + Hash, Accumulator: WindowAccumulator,

fn reap( &mut self, store: &mut dyn StateStore, key: &GroupStateKey, ) -> Result<()>