Method write

src/Storages/Distributed/DistributedBlockOutputStream.cpp:153–176

void DistributedBlockOutputStream::write(const Block & block)
{
    Block ordinary_block{ block };

    if (!allow_materialized)
    {
        /* They are added by the AddingDefaultBlockOutputStream, and we will get
         * different number of columns eventually */
        for (const auto & col : metadata_snapshot->getColumns().getMaterialized())
        {
            if (ordinary_block.has(col.name))
            {
                ordinary_block.erase(col.name);
                LOG_DEBUG(log, "{}: column {} will be removed, because it is MATERIALIZED",
                    storage.getStorageID().getNameForLogs(), col.name);
            }
        }
    }

    if (insert_sync)
        writeSync(ordinary_block);
    else
        writeAsync(ordinary_block);
}

void DistributedBlockOutputStream::writeAsync(const Block & block)
{