Function mz_compute::render::threshold::threshold_arrangement

source ยท
fn threshold_arrangement<G, K, V, T1, Bu2, T2, L>(
    arrangement: &Arranged<G, T1>,
    name: &str,
    logic: L,
) -> Arranged<G, TraceAgent<T2>>
where G: Scope, G::Timestamp: Lattice + Columnation, V: Data + Columnation, T1: TraceReader<Time = G::Timestamp, Diff = Diff> + Clone + 'static, for<'a> T1::Key<'a>: IntoOwned<'a, Owned = K>, for<'a> T1::Val<'a>: IntoOwned<'a, Owned = V>, K: Columnation + Data, Bu2: Builder<Time = G::Timestamp, Output = T2::Batch>, Bu2::Input: Container + PushInto<((K, V), G::Timestamp, Diff)>, T2: for<'a> Trace<Key<'a> = T1::Key<'a>, Val<'a> = T1::Val<'a>, Time = G::Timestamp, Diff = Diff> + 'static, T2::Batch: Batch, L: Fn(&Diff) -> bool + 'static, Arranged<G, TraceAgent<T2>>: ArrangementSize,
Expand description

Shared function to compute an arrangement of values matching logic.