Function ParseSchemaMergeMethods

src/common/stats_store.cpp:326–363

Parse merge strategy from schema (type_int + resolution_method).

// Parse merge strategy from schema (type_int + resolution_method).
std::unordered_map<uint32_t, StatMerge>
ParseSchemaMergeMethods(const std::vector<BkvNode>& schemaRoot) {
    std::unordered_map<uint32_t, StatMerge> out;

    const BkvNode* statsSec = nullptr;
    for (const auto& top : schemaRoot) {
        if (top.type != BKV_SECTION) continue;
        if (auto* s = BkvFind(top.children, "stats")) { statsSec = s; break; }
        if (top.name == "stats") { statsSec = &top; break; }
    }
    if (!statsSec) return out;

    for (const auto& stat : statsSec->children) {
        if (stat.type != BKV_SECTION) continue;
        bool numeric = !stat.name.empty();
        for (char c : stat.name) { if (c < '0' || c > '9') { numeric = false; break; } }
        if (!numeric) continue;
        uint32_t statId = (uint32_t)strtoul(stat.name.c_str(), nullptr, 10);

        int typeInt = 0, resMeth = 0;
        if (const BkvNode* ti = BkvFind(stat.children, "type_int"))
            typeInt = (int)ti->intVal;
        if (const BkvNode* rm = BkvFind(stat.children, "resolution_method"))
            resMeth = (int)rm->intVal;

        if (typeInt == 4) {
            out[statId] = StatMerge::BitwiseOr;
        } else if (resMeth == 1) {
            out[statId] = StatMerge::BitwiseOr;
        } else if (resMeth == 2) {
            // type_int: 1=INT (signed), 2=FLOAT, 3=AVGRATE (float)
            out[statId] = (typeInt >= 2) ? StatMerge::MaxFloat : StatMerge::MaxInt;
        } else {
            out[statId] = StatMerge::Overwrite;
        }
    }
    return out;
}

} // namespace