Data Operations

...

Aggregation Operation

/**
* Aggregation Callback
*/
void
aggregateCallback(LogEntryHandle handle, uint8_t type,
                      void *cookie)
{
        const Object* obj = handle->userData<Object>();
        MasterServer *server = reinterpret_cast<MasterServer*>(cookie);

        int *p;
        p = (int*) obj->data;
        server->sum += (uint64_t)*p;
}

#number of objects	client-side aggregation	server-side aggregation via hashtable lookup	server-side aggregation via hashtable forEach
10.000	75 ms
100.000	766 ms
1.000.000	7604 ms
10.000.000	76515 ms
100.000.000	770761 ms

s