Function differential_dataflow::capture::sink::build

source ·
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>,
Expand description

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.