Module linear_join 

Rendering of linear join plans.

Consult LinearJoinPlan documentation for details.

Structs

LinearJoinSpec

Specification of how linear joins are to be executed.

YieldSpec 🔒

Specification of a dataflow operator’s yielding behavior.

Enums

JoinedFlavor 🔒

Different forms the streamed data might take.

LinearJoinImpl 🔒

Available linear join implementations.

Functions

apply_join_closure 🔒

Unpacks one join match into datums and applies closure to it.

arrange_join_collection 🔒

Forms the arrangement for the intra-operator Vec accumulator of a linear join. Unlike arrange_join_input, the accumulator is a bare VecCollection rather than a collection edge: mz_join_core is Vec-internal, so the accumulator never carries the collection edge type.

arrange_join_input 🔒

Forms the source arrangement for a streamed join input off a collection edge.

arrange_keyed_join_input 🔒

Exchanges keyed join updates by key and arranges them into a RowRowSpine.

encode_updates 🔒

Re-encodes a Vec collection through CB.

key_join_input_vec 🔒

Keys a row-formatted join input stream into columnar ((key, value), t, d) updates, splitting off key-evaluation errors into a separate stream.