Skip to main content

derive_join_bindings

akar_processor::processor::join_helpers

Function derive_join_bindings 

Source 
pub fn derive_join_bindings(
    join_keys: &[Expression],
    build_chunks: &[DataChunk],
    probe_chunks: &[DataChunk],
) -> Vec<JoinKeyBinding>
Expand description

Resolve the build/probe column indices for a join condition. Returns one binding per Equal key.

Column resolution tries, in order:

  1. the fully-qualified property (m.id / row.id),
  2. the bare property name (id — scan columns use plain column names),
  3. a variable column holding map/struct values, with the key to extract (row + key id).

The cross-side fallback (try the opposite side’s expression) preserves the legacy behaviour when chunk field names are asymmetric.