mz_compute::render::join::delta_join

Function dispatch_build_update_stream_local

Source
fn dispatch_build_update_stream_local<G>(
    trace: MzArrangement<G>,
    as_of: Antichain<Timestamp>,
    source_relation: usize,
    initial_closure: JoinClosure,
) -> (Collection<G, Row, Diff>, Collection<G, DataflowError, Diff>)
where G: Scope, G::Timestamp: RenderTimestamp, <G::Timestamp as Columnar>::Container: Clone + Send, for<'a> <G::Timestamp as Columnar>::Ref<'a>: Ord + Copy,
Expand description

Dispatches building of a delta path update stream by to arrangement type specialization.