CPC G06F 16/2255 (2019.01) [G06F 16/134 (2019.01); G06F 16/2272 (2019.01); G06F 16/244 (2019.01); G06F 16/24556 (2019.01); G06F 16/285 (2019.01)] | 32 Claims |
1. A system, comprising:
a plurality of computing units, wherein a first computing node of the plurality of computing units comprises:
a communication interface configured to:
receive an indication to roll up data in a data table; and
a processor coupled to the communication interface and configured to:
build a preaggregation hash table based at least in part on a set of columns of the data table by aggregating input rows of the data table;
for each preaggregation hash table entry of the preaggregation hash table: provide the preaggregation hash table entry to one or more other computing units of the plurality of computing units based at least in part on a distribution hash value;
receive a set of entries from computing units of the plurality of computing units; and
build an aggregation hash table based at least in part on the set of entries by aggregating the set of entries.
|