Method NestedLoopJoin

src/Interpreters/NestedLoopJoin.cpp:46–85

}

NestedLoopJoin::NestedLoopJoin(std::shared_ptr<TableJoin> table_join_, const Block & right_sample_block_, const ContextPtr & context_)
    : table_join(table_join_)
    , right_sample_block(right_sample_block_)
    , size_limits(table_join->sizeLimits())
    , nullable_right_side(table_join->forceNullableRight())
    , is_any_join(isAny(table_join->strictness()))
    , is_left(isLeft(table_join->kind()))
    , max_rows_in_right_block(table_join->maxRowsInRightBlock())
    , context(context_)
{
    if (!isLeft(table_join->kind()) && !isInner(table_join->kind()))
        throw Exception("NestedLoop join supported for LEFT and INNER JOINs only", ErrorCodes::NOT_IMPLEMENTED);

    if (is_any_join)
        throw Exception("NestedLoop join is not supported for any join", ErrorCodes::NOT_IMPLEMENTED);

    if (!max_rows_in_right_block)
        throw Exception("partial_nested_loop_join_rows_in_right_blocks cannot be zero", ErrorCodes::PARAMETER_OUT_OF_BOUND);

    if (!size_limits.hasLimits())
    {
        size_limits.max_bytes = table_join->defaultMaxBytes();
        if (!size_limits.max_bytes)
            throw Exception(
                "No limit for NestedLoop join (max_rows_in_join, max_bytes_in_join or default_max_bytes_in_join have to be set)",
                ErrorCodes::PARAMETER_OUT_OF_BOUND);
    }
    table_join->splitAdditionalColumns(right_sample_block, right_table_keys, right_columns_to_add);
    JoinCommon::removeLowCardinalityInplace(right_columns_to_add);
    JoinCommon::createMissedColumns(right_columns_to_add);

    const NameSet required_right_keys = table_join->requiredRightKeys();
    for (const auto & column : right_table_keys)
        if (required_right_keys.count(column.name))
            right_columns_to_add.insert(ColumnWithTypeAndName{nullptr, column.type, column.name});
    JoinCommon::createMissedColumns(right_columns_to_add);

    if (nullable_right_side)
        JoinCommon::convertColumnsToNullable(right_columns_to_add);
}

void NestedLoopJoin::setTotals(const Block & totals_block)
{