Method Merge

cpp/core/RocksDBUtils.cpp:17–33

class Int64AddOperator : public rocksdb::AssociativeMergeOperator {
public:
    bool Merge(
        const rocksdb::Slice& key, const rocksdb::Slice* existing_value,
        const rocksdb::Slice& value, std::string* new_value,
        rocksdb::Logger* logger
    ) const override {
        int64_t orig_value = 0;
        if (existing_value) {
            orig_value = ExternalValue<I64Value>::FromSlice(*existing_value)().i64();
        }
        int64_t operand = ExternalValue<I64Value>::FromSlice(value)().i64();

        ALWAYS_ASSERT(new_value);
        new_value->resize(I64Value::MAX_SIZE);
        ExternalValue<I64Value>(*new_value)().setI64(orig_value + operand);

        return true;
    }

    const char* Name() const override { return "Int64AddOperator"; }
    const char* NickName() const override { return "int64add"; }