Trait timely::dataflow::operators::delay::Delay

pub trait Delay<G: Scope, D: Data> {
    fn delay<F: Fn(&D, &G::Timestamp) -> G::Timestamp + 'static>(&self, F) -> Self;
    fn delay_batch<F: Fn(&G::Timestamp) -> G::Timestamp + 'static>(&self, F) -> Self;
}

Required Methods

fn delay<F: Fn(&D, &G::Timestamp) -> G::Timestamp + 'static>(&self, F) -> Self

fn delay_batch<F: Fn(&G::Timestamp) -> G::Timestamp + 'static>(&self, F) -> Self

Implementors

• impl<G: Scope, D: Data> Delay<G, D> for Stream<G, D> where G::Timestamp: Hash