Skip to main content

threshold_arrangement

Function threshold_arrangement 

Source
fn threshold_arrangement<'scope, Ts, T1, Bu2, T2, L>(
    arrangement: Arranged<'scope, T1>,
    name: &str,
    logic: L,
) -> Arranged<'scope, TraceAgent<T2>>
where Ts: MzTimestamp, T1: TraceReader<KeyContainer: BatchContainer<Owned: MzData + Data>, ValOwn: MzData + Data, Time = Ts, Diff = Diff> + Clone + 'static, Bu2: Builder<Time = Ts, Input: Container + InternalMerge + ClearContainer + PushInto<((<T1::KeyContainer as BatchContainer>::Owned, T1::ValOwn), Ts, Diff)>, Output = T2::Batch>, T2: for<'a> Trace<Key<'a> = T1::Key<'a>, Val<'a> = T1::Val<'a>, KeyContainer: BatchContainer<Owned = <T1::KeyContainer as BatchContainer>::Owned>, ValOwn = T1::ValOwn, Time = Ts, Diff = Diff> + 'static, L: Fn(&Diff) -> bool + 'static, Arranged<'scope, TraceAgent<T2>>: ArrangementSize,
Expand description

Shared function to compute an arrangement of values matching logic.