Function adoptBlock

src/Storages/Distributed/DistributedBlockOutputStream.cpp:85–99

}

static Block adoptBlock(const Block & header, const Block & block, Poco::Logger * log)
{
    if (blocksHaveEqualStructure(header, block))
        return block;

    LOG_WARNING(log,
        "Structure does not match (remote: {}, local: {}), implicit conversion will be done.",
        header.dumpStructure(), block.dumpStructure());

    ConvertingBlockInputStream convert(
        std::make_shared<OneBlockInputStream>(block),
        header,
        ConvertingBlockInputStream::MatchColumnsMode::Name);
    return convert.read();
}


static void writeBlockConvert(const BlockOutputStreamPtr & out, const Block & block, size_t repeats, Poco::Logger * log)