pub struct TumblingCarryEngine<G, S: WindowAnchor, Accumulator, Carry, Output> { /* private fields */ }Implementations§
Source§impl<G, S, Accumulator, Carry, Output> TumblingCarryEngine<G, S, Accumulator, Carry, Output>where
G: Clone + Eq + Ord + Hash + Debug + StateCodec,
S: WindowAnchor + Hash + HeapSize,
Accumulator: WindowAccumulator,
Carry: Clone + Debug + HeapSize,
Output: Clone + Debug + HeapSize,
CarryMeta<S, Carry, Output>: OperatorState,
impl<G, S, Accumulator, Carry, Output> TumblingCarryEngine<G, S, Accumulator, Carry, Output>where
G: Clone + Eq + Ord + Hash + Debug + StateCodec,
S: WindowAnchor + Hash + HeapSize,
Accumulator: WindowAccumulator,
Carry: Clone + Debug + HeapSize,
Output: Clone + Debug + HeapSize,
CarryMeta<S, Carry, Output>: OperatorState,
pub fn new(config: TumblingCarryConfig<S>) -> Self
pub fn expire_meta( &mut self, store: &mut dyn StateStore, threshold: u64, ) -> Result<usize>
pub fn apply<K, NA, BO, CF>( &mut self, store: &mut dyn StateStore, buckets: TumblingBuckets<G, S, Accumulator::Contribution>, row_key: K, new_accumulator: NA, build_output: BO, carry_forward: CF, ) -> Result<Vec<WindowResult<G, S, Output>>>
Auto Trait Implementations§
impl<G, S, Accumulator, Carry, Output> Freeze for TumblingCarryEngine<G, S, Accumulator, Carry, Output>where
Option<<<S as Slot>::Coord as Coord>::Span>: Freeze,
PhantomData<(G, Accumulator, Carry, Output)>: Freeze,
impl<G, S, Accumulator, Carry, Output> RefUnwindSafe for TumblingCarryEngine<G, S, Accumulator, Carry, Output>where
Option<<<S as Slot>::Coord as Coord>::Span>: RefUnwindSafe,
PhantomData<(G, Accumulator, Carry, Output)>: RefUnwindSafe,
impl<G, S, Accumulator, Carry, Output> Send for TumblingCarryEngine<G, S, Accumulator, Carry, Output>where
Option<<<S as Slot>::Coord as Coord>::Span>: Send,
PhantomData<(G, Accumulator, Carry, Output)>: Send,
impl<G, S, Accumulator, Carry, Output> Sync for TumblingCarryEngine<G, S, Accumulator, Carry, Output>where
Option<<<S as Slot>::Coord as Coord>::Span>: Sync,
PhantomData<(G, Accumulator, Carry, Output)>: Sync,
impl<G, S, Accumulator, Carry, Output> Unpin for TumblingCarryEngine<G, S, Accumulator, Carry, Output>where
Option<<<S as Slot>::Coord as Coord>::Span>: Unpin,
PhantomData<(G, Accumulator, Carry, Output)>: Unpin,
impl<G, S, Accumulator, Carry, Output> UnsafeUnpin for TumblingCarryEngine<G, S, Accumulator, Carry, Output>where
Option<<<S as Slot>::Coord as Coord>::Span>: UnsafeUnpin,
PhantomData<(G, Accumulator, Carry, Output)>: UnsafeUnpin,
impl<G, S, Accumulator, Carry, Output> UnwindSafe for TumblingCarryEngine<G, S, Accumulator, Carry, Output>where
Option<<<S as Slot>::Coord as Coord>::Span>: UnwindSafe,
PhantomData<(G, Accumulator, Carry, Output)>: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more