Method collectFilesForClearMapKey

src/WorkerTasks/MergeTreeDataMutator.cpp:507–538

}

NameSet MergeTreeDataMutator::collectFilesForClearMapKey(MergeTreeData::DataPartPtr source_part, const MutationCommands & commands)
{
    NameSet clear_map_key_set;
    const auto & metadata_snapshot = source_part->storage.getInMemoryMetadata();
    for (const auto & command : commands)
    {
        if (command.type != MutationCommand::Type::CLEAR_MAP_KEY)
            continue;

        /// Collect all file names of the implicit key name.
        NameSet file_set;

        String map_name = command.column_name;
        const auto & map_column = metadata_snapshot.columns.getPhysical(map_name);
        const auto & map_type = typeid_cast<const DataTypeMap &>(*map_column.type);
        /// Remove all files of the implicit key name
        for (const auto & map_key_ast : command.map_keys->children)
        {
            const auto * key_lit = map_key_ast->as<ASTLiteral>();
            String key_name = convertToMapKeyString(map_type.getKeyType(), key_lit->getColumnName());

            for (const auto & [file, _] : source_part->getChecksums()->files)
            {
                if (isMapBaseFile(file))
                    continue;
                if (isMapImplicitFileNameOfSpecialMapName(file, map_name) && parseKeyNameFromImplicitFileName(file, map_name) == key_name)
                    clear_map_key_set.emplace(file);
            }
        }
    }
    return clear_map_key_set;
}


NameToNameVector MergeTreeDataMutator::collectFilesForRenames(