Trait timely::dataflow::operators::capture::replay::Replay

pub trait Replay<T: Timestamp, D: Data>: Sized {
    fn replay_core<S: Scope<Timestamp = T>>(
        self, 
        scope: &mut S, 
        period: Option<Duration>
    ) -> Stream<S, D>;

    fn replay_into<S: Scope<Timestamp = T>>(self, scope: &mut S) -> Stream<S, D> { ... }
}

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

Required methods

fn replay_core<S: Scope<Timestamp = T>>(
    self,
    scope: &mut S,
    period: Option<Duration>
) -> 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. The None argument instructs the operator not to re-activate itself.us

Loading content...

Provided methods

fn replay_into<S: Scope<Timestamp = T>>(self, scope: &mut S) -> Stream<S, D>

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

Loading content...

Implementors

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

fn replay_core<S: Scope<Timestamp = T>>(
    self,
    scope: &mut S,
    period: Option<Duration>
) -> Stream<S, D>

Loading content...