Function mz_compute::render::join::delta_join::dispatch_build_halfjoin_trace

source ยท
fn dispatch_build_halfjoin_trace<G, T, CF>(
    updates: Collection<G, (Row, G::Timestamp), Diff>,
    trace: MzArrangementImport<G, T>,
    prev_key: Vec<MirScalarExpr>,
    prev_thinning: Vec<usize>,
    comparison: CF,
    closure: JoinClosure,
    shutdown_token: ShutdownToken,
) -> (Collection<G, (Row, G::Timestamp), Diff>, Collection<G, DataflowError, Diff>)
where G: Scope, T: Timestamp + Lattice + Columnation, G::Timestamp: Lattice + RenderTimestamp + Refines<T> + Columnation, CF: Fn(&G::Timestamp, &G::Timestamp) -> bool + 'static,
Expand description

Dispatches half-join construction according to trace type specialization.