Method getCheckTaskList

src/Storages/StorageMergeTree.cpp:3058–3090

}

IStorage::DataValidationTasksPtr StorageMergeTree::getCheckTaskList(
    const std::variant<std::monostate, ASTPtr, String> & check_task_filter, ContextPtr local_context)
{
    /// TODO(unique-key): sidecar-aware check. The per-part delete-bitmap
    /// sidecars are not enumerated as part artifacts, so checkDataPart treats
    /// them as UNEXPECTED_FILE_IN_DATA_PART. Reject for now.
    if (auto uk_metadata = getInMemoryMetadataPtr(local_context, false); uk_metadata && uk_metadata->hasUniqueKey())
        throw Exception(ErrorCodes::SUPPORT_IS_DISABLED,
            "CHECK TABLE is not supported for UNIQUE KEY tables yet: delete-bitmap "
            "sidecars are not yet recognized as part artifacts.");

    DataPartsVector data_parts;
    if (const auto * partition_opt = std::get_if<ASTPtr>(&check_task_filter))
    {
        const auto & partition = *partition_opt;
        if (!partition->as<ASTPartition>())
            throw Exception(ErrorCodes::LOGICAL_ERROR, "Expected partition, got {}", partition->formatForErrorMessage());
        String partition_id = getPartitionIDFromQuery(partition, local_context);
        data_parts = getVisibleDataPartsVectorInPartition(local_context, partition_id);
    }
    else if (const auto * part_name = std::get_if<String>(&check_task_filter))
    {
        auto part = getPartIfExists(*part_name, {MergeTreeDataPartState::Active, MergeTreeDataPartState::Outdated});
        if (!part)
            throw Exception(ErrorCodes::NO_SUCH_DATA_PART, "No such data part '{}' to check in table '{}'",
                            *part_name, getStorageID().getFullTableName());
        data_parts.emplace_back(std::move(part));
    }
    else
        data_parts = getVisibleDataPartsVector(local_context);

    return std::make_unique<DataValidationTasks>(std::move(data_parts), local_context);
}

std::optional<CheckResult> StorageMergeTree::checkDataNext(DataValidationTasksPtr & check_task_list)
{