Function mz_compute::render::join::delta_join::dispatch_build_update_stream_trace
source ยท fn dispatch_build_update_stream_trace<G, T>(
trace: MzArrangementImport<G, T>,
as_of: Antichain<Timestamp>,
source_relation: usize,
initial_closure: JoinClosure,
) -> (Collection<G, Row, Diff>, Collection<G, DataflowError, Diff>)where
G: Scope,
T: Timestamp + Lattice + Columnation,
G::Timestamp: Lattice + RenderTimestamp + Refines<T> + Columnation,
Expand description
Dispatches building of a delta path update stream by to trace type specialization.