Method executeClusterTask

src/WorkerTasks/MergeTreeDataReclusterMutator.cpp:37–49

}

MergeTreeMutableDataPartsVector MergeTreeDataReclusterMutator::executeClusterTask(
    const ManipulationTaskParams & params,
    ManipulationListEntry & manipulation_entry,
    ContextPtr context)
{
    MergeTreeMutableDataPartsVector clustered_parts;
    for (auto & part : params.source_data_parts)
    {
        auto new_parts = executeOnSinglePart(part, params, manipulation_entry, context);
        clustered_parts.insert(clustered_parts.end(), new_parts.begin(), new_parts.end());
    }
    return clustered_parts;
}

MergeTreeMutableDataPartsVector MergeTreeDataReclusterMutator::executeOnSinglePart(
    const MergeTreeDataPartPtr & part,