Skip to main content

bundle_errs

Function bundle_errs 

Source
fn bundle_errs<'scope, T: RenderTimestamp>(
    bundle: &CollectionBundle<'scope, T>,
) -> Vec<VecCollection<'scope, T, DataflowErrorSer, Diff>> 
Expand description

The error collections of every collection and arrangement bundle holds.

A delta join reads every input from every one of its paths, but an input’s pre-existing errors belong in the join’s error output once. Propagating them per path would multiply their multiplicities by the number of paths, and because a join’s output is another join’s input, those factors compound multiplicatively through a nested plan until the Diff overflows. Error semantics depend only on presence, so the extra copies buy nothing.

Expects the pruned bundle (see prune_bundle), so that it yields errors only for the collections some path actually reads.

NOTE: This bounds an input’s errors to one copy per retained form, not to one copy outright. Each form carries its own error collection, and an arrangement’s is a distinct stream built from the raw one plus that key’s key-formation errors, so an input the join reads under two lookup keys still contributes its errors twice. Reachable whenever a delta path set needs an error-carrying input arranged by more than one key.