Trait dataflow::replay::MzReplay

pub trait MzReplay<T: Timestamp, D: Data>: Sized {
    fn mz_replay<S: Scope<Timestamp = T>>(
        self, 
        scope: &mut S, 
        name: &str, 
        perid: Duration, 
        rc_activator: RcActivator
    ) -> Stream<S, D>;
}

Replay a capture stream into a scope with the same timestamp.

Required methods

fn mz_replay<S: Scope<Timestamp = T>>(
    self,
    scope: &mut S,
    name: &str,
    perid: Duration,
    rc_activator: RcActivator
) -> Stream<S, D>

Replays self into the provided scope, as a `Stream<S, D>’.

The period argument allows the specification of a re-activation period, where the operator will re-activate itself every so often.

Implementors

impl<T: Timestamp, D: Data, I> MzReplay<T, D> for I where
    I: IntoIterator,
    <I as IntoIterator>::Item: EventIterator<T, D> + 'static,