Trait mz_compute::render::continual_task::TimesReduce

trait TimesReduce<G: Scope, R> {
    // Required method
    fn times_reduce(&self, name: &str) -> Collection<G, (), R>;
}

Required Methods

fn times_reduce(&self, name: &str) -> Collection<G, (), R>

This is essentially a specialized impl of consolidate, with a HashMap instead of the Trace.

Implementations on Foreign Types

impl<G, R> TimesReduce<G, R> for Collection<G, (), R>

where G: Scope<Timestamp = Timestamp>, R: Semigroup + 'static + Debug,

fn times_reduce(&self, name: &str) -> Collection<G, (), R>

Implementors