Method writeTempPart

src/Storages/MergeTree/MergeTreeDataWriter.cpp:356–637

}

MergeTreeMetaBase::MutableDataPartPtr MergeTreeDataWriter::writeTempPart(
    BlockWithPartition & block_with_partition, const StorageMetadataPtr & metadata_snapshot, ContextPtr context, UInt64 block_id, Int64 mutation, Int64 hint_mutation)
{
    Block & block = block_with_partition.block;
    Int64 bucket_number = block_with_partition.bucket_info.bucket_number;

    auto columns = metadata_snapshot->getColumns().getAllPhysical().filter(block.getNames());
    auto storage_snapshot = data.getStorageSnapshot(metadata_snapshot, context);

    if (metadata_snapshot->hasDynamicSubcolumns())
    {
        convertDynamicColumnsToTuples(block, storage_snapshot);
    }

    for (auto & column : columns)
        if (column.type->hasDynamicSubcolumns())
            column.type = block.getByName(column.name).type;

    static const String TMP_PREFIX = "tmp_insert_";

    /// This will generate unique name in scope of current server process.
    Int64 temp_index = block_id ? block_id : data.insert_increment.get();

    IMergeTreeDataPart::MinMaxIndex minmax_idx;
    minmax_idx.update(block, data.getMinMaxColumnsNames(metadata_snapshot->getPartitionKey()));

    MergeTreePartition partition(std::move(block_with_partition.partition));

    MergeTreePartInfo new_part_info(
        partition.getID(metadata_snapshot->getPartitionKey().sample_block, data.extractNullableForPartitionID()),
        /*min_block_*/temp_index,
        /*max_block_*/temp_index,
        /*level_*/0,
        mutation,
        hint_mutation);
    String part_name;
    if (data.format_version < MERGE_TREE_DATA_MIN_FORMAT_VERSION_WITH_CUSTOM_PARTITIONING)
    {
        DayNum min_date(minmax_idx.hyperrectangle[data.minmax_idx_date_column_pos].left.get<UInt64>());
        DayNum max_date(minmax_idx.hyperrectangle[data.minmax_idx_date_column_pos].right.get<UInt64>());

        const auto & date_lut = DateLUT::serverTimezoneInstance();

        auto min_month = date_lut.toNumYYYYMM(min_date);
        auto max_month = date_lut.toNumYYYYMM(max_date);

        if (min_month != max_month)
            throw Exception("Logical error: part spans more than one month.", ErrorCodes::LOGICAL_ERROR);

        part_name = new_part_info.getPartNameV0(min_date, max_date);
    }
    else
        part_name = new_part_info.getPartName();

    /// If we need to calculate some columns to sort.
    if (metadata_snapshot->hasSortingKey() || metadata_snapshot->hasSecondaryIndices())
        data.getSortingKeyAndSkipIndicesExpression(metadata_snapshot)->execute(block);