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_closure 🔒

Applies closure to the datums of one record, packing the row it computes.

apply_closure_to_edge 🔒

Applies closure to every record of edge, writing the rows it computes onto the output edge.

apply_join_closure 🔒

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

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.

demux_join_results 🔒

Splits a stage’s Results, writing the rows onto the edge and the errors to a Vec.

encode_updates 🔒

Re-encodes a Vec collection through CB.