Function evaluate_join

ciphercore-base/src/evaluators/join.rs:501–561

(
    join_t: JoinType,
    set0_tv: TypedValue,
    set1_tv: TypedValue,
    has_column_masks: bool,
    headers: &HashMap<String, String>,
    res_t: Type,
)

}

pub(crate) fn evaluate_join(
    join_t: JoinType,
    set0_tv: TypedValue,
    set1_tv: TypedValue,
    has_column_masks: bool,
    headers: &HashMap<String, String>,
    res_t: Type,
) -> Result<Value> {
    if join_t == JoinType::Full {
        return evaluate_full_join(set0_tv, set1_tv, has_column_masks, headers, res_t);
    }
    let headers_types1 = get_named_types(&set1_tv.t)?;
    // Extract columns of the second set
    let set1 = extract_columns(&set1_tv, headers_types1, has_column_masks)?;

    let (key_headers0, key_headers1): (Vec<_>, Vec<_>) = headers.clone().into_iter().unzip();
    // Key columns of the second set are merged and added to the hash map along with the corresponding rows
    let key_data_hashmap1 = get_hashmap_from_key_columns(&set1, &key_headers1)?;

    let headers_types0 = get_named_types(&set0_tv.t)?;
    // Extract columns of the first set
    let set0 = extract_columns(&set0_tv, headers_types0, has_column_masks)?;

    let result_headers_types = get_named_types(&res_t)?;

    let mut nonkey_headers1 = vec![];
    for (h, _) in headers_types1 {
        if h != NULL_HEADER && !key_headers1.contains(h) {
            nonkey_headers1.push((*h).clone());
        }
    }
    let mut same_headers = vec![];
    for (h, _) in headers_types0 {
        if nonkey_headers1.contains(h) {
            same_headers.push((*h).clone());
        }
    }

    let join_input = JoinInput {
        set0,
        set1,
        headers_types0,
        key_headers0,
        nonkey_headers1,
        key_headers_map: headers.clone(),
        key_data_hashmap1,
        result_headers_types,
        same_headers,
    };

    let res_columns = match join_t {
        JoinType::Inner => get_inner_join_columns(&join_input)?,
        JoinType::Left => get_left_join_columns(&join_input)?,
        JoinType::Union => get_union_columns(&join_input)?,
        JoinType::Full => {
            // Full join is computed via left and union joins
            return Err(runtime_error!("Shouldn't be here"));
        }