Trait declarative_dataflow::sinks::Sinkable

pub trait Sinkable<T> where
    T: Timestamp + Lattice + Into<Time>, {
    fn sink<S, P>(
        &self, 
        stream: &Stream<S, ResultDiff<T>>, 
        pact: P, 
        probe: &mut ProbeHandle<T>, 
        context: SinkingContext
    ) -> Result<Option<Stream<S, Output>>, Error>
    where
        S: Scope<Timestamp = T>,
        P: ParallelizationContract<S::Timestamp, ResultDiff<T>>;
}

An external system that wants to receive result diffs.

Required methods

fn sink<S, P>(
    &self,
    stream: &Stream<S, ResultDiff<T>>,
    pact: P,
    probe: &mut ProbeHandle<T>,
    context: SinkingContext
) -> Result<Option<Stream<S, Output>>, Error> where
    S: Scope<Timestamp = T>,
    P: ParallelizationContract<S::Timestamp, ResultDiff<T>>, 

Creates a timely operator feeding dataflow outputs to a specialized data sink.

Loading content...

Implementors

impl<T> Sinkable<T> for Sink where
    T: Timestamp + Lattice + Default + Into<Time>, 

fn sink<S, P>(
    &self,
    stream: &Stream<S, ResultDiff<T>>,
    pact: P,
    probe: &mut ProbeHandle<T>,
    context: SinkingContext
) -> Result<Option<Stream<S, Output>>, Error> where
    S: Scope<Timestamp = T>,
    P: ParallelizationContract<S::Timestamp, ResultDiff<T>>, 

Loading content...