Function mz_compute::render::join::delta_join::dispatch_build_halfjoin_local
source · fn dispatch_build_halfjoin_local<G, CF>(
updates: Collection<G, (Row, G::Timestamp), Diff>,
trace: SpecializedArrangement<G>,
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,
G::Timestamp: RenderTimestamp,
CF: Fn(&G::Timestamp, &G::Timestamp) -> bool + 'static,
Expand description
Dispatches half-join construction according to arrangement type specialization.