Method loadRightBlock

src/Interpreters/MergeJoin.cpp:1156–1176

template <bool in_memory>
std::shared_ptr<Block> MergeJoin::loadRightBlock(size_t pos) const
{
    if constexpr (!in_memory)
    {
        auto load_func = [&]() -> std::shared_ptr<Block>
        {
            auto input = flushed_right_blocks[pos].getReadStream();
            auto result = std::make_shared<Block>(input->read());
            if (Block eof_block = input->read(); !eof_block.empty())
            {
                throw Exception(ErrorCodes::LOGICAL_ERROR, "Expected one block per file, got block {} in file {}",
                    eof_block.dumpStructure(), flushed_right_blocks[pos].getHolder()->describeFilePath());
            }
            return result;
        };

        return cached_right_blocks->getOrSet(pos, load_func).first;
    }
    else
        return loaded_right_blocks[pos];
}

void MergeJoin::initRightTableWriter()
{