Module delta_join 

Delta join execution dataflow construction.

Consult DeltaJoinPlan documentation for details.

Functions

build_halfjoin 🔒

Constructs a half_join against the arrangement held by a collection bundle.

build_halfjoin1 🔒

Original half_join implementation (fallback).

build_halfjoin2 🔒

half_join2 implementation (less-quadratic, new default).

build_halfjoin_trace 🔒

Constructs a half_join from supplied arguments.

build_update_stream 🔒

Builds the initial update stream of a delta path from a collection bundle.

build_update_stream_stream 🔒

Builds the beginning of the update stream of a delta path from a raw collection.

build_update_stream_trace 🔒

Builds the beginning of the update stream of a delta path.

prune_bundle 🔒

Retains only the collections of bundle a delta path reads: the arrangements keyed by keys, and the raw collection if raw. Every other collection is dropped.

record_path_arrangements 🔒

Records what a single delta path reads from each input: each stage’s lookup_key and, for the seed relation, either its source_key arrangement or, when source_key is None, its raw collection (flagged in raw).