Module cross_join 

Defines the cross join plan for loading the left side of the cross join and producing batches in parallel for the right partitions

Structs

CrossJoinExec

Cross Join Execution Plan

CrossJoinStream 🔒

A stream that issues [RecordBatch]es as they arrive from the right of the join.

JoinLeftData 🔒

Data of the left side that is buffered into memory

Enums

CrossJoinStreamState 🔒

Represents states of CrossJoinStream

Functions

build_batch 🔒

load_left_input 🔒

Asynchronously collect the result of the left child

stats_cartesian_product 🔒

[left/right]_col_count are required in case the column statistics are None