Skip to main content

build_update_stream

Function build_update_stream 

Source
fn build_update_stream<'scope, T>(
    bundle: &CollectionBundle<'scope, T>,
    as_of: Antichain<Timestamp>,
    source_key: Option<Vec<LirScalarExpr>>,
    source_relation: usize,
    initial_closure: JoinClosure,
) -> (VecCollection<'scope, T, Row, Diff>, VecCollection<'scope, T, DataflowErrorSer, Diff>)
where T: RenderTimestamp,
Expand description

Builds the initial update stream of a delta path from a collection bundle.

With a source_key, demuxes over the two flavors of arrangement the bundle might hold for that key, dispatching to the generic build_update_stream_trace. Without a source_key, the source relation is consumed as a raw (unarranged) collection via build_update_stream_stream.

The returned error collection holds only the errors the initial closure produces. The errors bundle already carries are the caller’s to propagate, once, rather than once per delta path. See bundle_errs.