Module lookup_join_exec 

Physical execution plan and extension planner for lookup joins. Physical execution plan for lookup joins.

Bridges LookupJoinNode (logical) to a hash-probe executor that joins streaming input against a pre-indexed lookup table snapshot.

Data flow

Stream input ──► LookupJoinExec ──► Output (stream + lookup columns)
                      │
                 HashIndex probe
                      │
                 LookupSnapshot (pre-indexed RecordBatch)

Structs

LookupJoinExec

Physical plan that hash-probes a pre-indexed lookup table for each batch from the streaming input.

LookupJoinExtensionPlanner

Converts LookupJoinNode logical plans to LookupJoinExec or PartialLookupJoinExec physical plans by resolving table data from the registry.

LookupSnapshot

Point-in-time snapshot of a lookup table for join execution.

LookupTableRegistry

Thread-safe registry of lookup table entries (snapshot or partial).

PartialLookupJoinExec

Physical plan that probes a bounded lookup cache per key for each input batch.

PartialLookupState

State for a partial (on-demand) lookup table.

Enums

RegisteredLookup

A registered lookup table entry — snapshot or partial (on-demand).