Trait declarative_dataflow::sources::Sourceable

pub trait Sourceable<S> where
    S: Scope,
    S::Timestamp: Timestamp + Lattice, {
    fn source(
        &self, 
        scope: &mut S, 
        context: SourcingContext<S::Timestamp>
    ) -> Vec<(Aid, AttributeConfig, Stream<S, ((Value, Value), S::Timestamp, isize)>)>;
}

An external data source that can provide Datoms.

Required methods

fn source(
    &self,
    scope: &mut S,
    context: SourcingContext<S::Timestamp>
) -> Vec<(Aid, AttributeConfig, Stream<S, ((Value, Value), S::Timestamp, isize)>)>

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

Loading content...

Implementors

impl<S: Scope<Timestamp = Duration>> Sourceable<S> for TimelyLogging

fn source(
    &self,
    scope: &mut S,
    context: SourcingContext<S::Timestamp>
) -> Vec<(Aid, AttributeConfig, Stream<S, ((Value, Value), Duration, isize)>)>

impl<S: Scope<Timestamp = Duration>> Sourceable<S> for DifferentialLogging

fn source(
    &self,
    scope: &mut S,
    context: SourcingContext<S::Timestamp>
) -> Vec<(Aid, AttributeConfig, Stream<S, ((Value, Value), Duration, isize)>)>

impl<S: Scope> Sourceable<S> for Source where
    S::Timestamp: Timestamp + Lattice, 

fn source(
    &self,
    _scope: &mut S,
    _context: SourcingContext<S::Timestamp>
) -> Vec<(Aid, AttributeConfig, Stream<S, ((Value, Value), S::Timestamp, isize)>)>

Loading content...