Method mergeInMemoryRightBlocks

src/Interpreters/MergeJoin.cpp:667–709

}

void MergeJoin::mergeInMemoryRightBlocks()
{
    std::lock_guard lock(rwlock);

    if (right_blocks.empty())
        return;

    Pipe source(std::make_shared<BlocksListSource>(std::move(right_blocks.blocks)));
    right_blocks.clear();

    QueryPipelineBuilder builder;
    builder.init(std::move(source));

    /// TODO: there should be no split keys by blocks for RIGHT|FULL JOIN
    builder.addTransform(std::make_shared<MergeSortingTransform>(
        builder.getSharedHeader(),
        right_sort_description,
        max_rows_in_right_block,
        /*max_block_bytes=*/0,
        /*limit_=*/0,
        /*increase_sort_description_compile_attempts=*/false,
        /*max_bytes_before_remerge_*/0,
        /*remerge_lowered_memory_bytes_ratio_*/0,
        /*max_bytes_in_block_before_external_sort_*/0,
        /*max_bytes_in_query_before_external_sort_*/0,
        /*tmp_data_*/nullptr,
        /*min_free_disk_space_*/0));

    auto pipeline = QueryPipelineBuilder::getPipeline(std::move(builder));
    PullingPipelineExecutor executor(pipeline);

    Block block;
    while (executor.pull(block))
    {
        if (!block.rows())
            continue;

        if (skip_not_intersected)
            min_max_right_blocks.emplace_back(extractMinMax(block, right_table_keys));
        right_blocks.countBlockSize(block);
        loaded_right_blocks.emplace_back(std::make_shared<Block>(std::move(block)));
    }
}

void MergeJoin::mergeFlushedRightBlocks()
{