Trait declarative_dataflow::sources::Sourceable

pub trait Sourceable<T> where
    T: Timestamp + Lattice + TotalOrder, {
    fn source<S: Scope<Timestamp = T>>(
        &self, 
        scope: &mut S, 
        t0: Instant, 
        scheduler: Weak<RefCell<Scheduler>>
    ) -> Vec<(Aid, Stream<S, ((Value, Value), T, isize)>)>;
}

An external data source that can provide Datoms.

Required methods

fn source<S: Scope<Timestamp = T>>(
    &self,
    scope: &mut S,
    t0: Instant,
    scheduler: Weak<RefCell<Scheduler>>
) -> Vec<(Aid, Stream<S, ((Value, Value), T, isize)>)>

Conjures from thin air (or from wherever the source lives) one or more timely streams feeding directly into attributes.

Loading content...

Implementors

impl Sourceable<u64> for Source

fn source<S: Scope<Timestamp = u64>>(
    &self,
    _scope: &mut S,
    _t0: Instant,
    _scheduler: Weak<RefCell<Scheduler>>
) -> Vec<(Aid, Stream<S, ((Value, Value), u64, isize)>)>

impl Sourceable<Duration> for DifferentialLogging

fn source<S: Scope<Timestamp = Duration>>(
    &self,
    scope: &mut S,
    _t0: Instant,
    _scheduler: Weak<RefCell<Scheduler>>
) -> Vec<(Aid, Stream<S, ((Value, Value), Duration, isize)>)>

impl Sourceable<Duration> for TimelyLogging

fn source<S: Scope<Timestamp = Duration>>(
    &self,
    scope: &mut S,
    _t0: Instant,
    _scheduler: Weak<RefCell<Scheduler>>
) -> Vec<(Aid, Stream<S, ((Value, Value), Duration, isize)>)>

Loading content...