Trait mz_compute::render::continual_task::TimesExtract

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

Required Methods

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

Returns a collection with the times changed in the input collection.

This works by mapping the data piece of the differential tuple to (). It is essentially the same as the following, but without cloning everything in the input.

input.map(|(_data, ts, diff)| ((), ts, diff))

The output may be partially consolidated, but no consolidation guarantees are made.

Implementations on Foreign Types

impl<G, D, R> TimesExtract<G, D, R> for Collection<G, D, R>

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

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

Implementors