Function differential_dataflow::capture::sink::build

pub fn build<G, BS, D, T, R>(
    stream: &Stream<G, (D, T, R)>,
    sink_hash: u64,
    updates_sink: Weak<RefCell<BS>>,
    progress_sink: Weak<RefCell<BS>>,
)
where
    G: Scope<Timestamp = T>,
    BS: Writer<Message<D, T, R>> + 'static,
    D: ExchangeData + Hash + Serialize + for<'a> Deserialize<'a>,
    T: ExchangeData + Hash + Serialize + for<'a> Deserialize<'a> + Timestamp + Lattice,
    R: ExchangeData + Hash + Serialize + for<'a> Deserialize<'a>,

Constructs a sink, for recording the updates in stream.

It is crucial that stream has been consolidated before this method, which will not perform the consolidation on the stream’s behalf. If this is not performed before calling the method, the recorded output may not be correctly reconstructed by readers.