CPC A63F 13/75 (2014.09) [A63F 13/216 (2014.09); A63F 13/358 (2014.09); A63F 13/73 (2014.09); A63F 13/79 (2014.09); A63F 2300/534 (2013.01); A63F 2300/5546 (2013.01); A63F 2300/5586 (2013.01)] | 20 Claims |
1. A method comprising:
receiving a batch of data generated by one or more client devices;
generating portions of the batch of data by aggregating the same or similar types of data of the batch of data;
identifying nodes to receive the portions of the data based on the nodes' availability to process data, each node being an independent processing unit;
broadcasting the portions of the data to the nodes, wherein broadcasting the portions of the data begins prior to receiving the entire batch of data;
receiving, by accumulation layers of the nodes, the portions of the data;
nodes independently generating metrics based on the received portions of the data, wherein each node begins generating one or more metrics after the node's accumulation layer receives a threshold amount of data; and
each node adding the one or more generated metrics to a relational database unable to add all of the metrics generated by the nodes at once, wherein the one or more metrics generated by each node are added to the relational database (a) responsive to completion of generating the one or more metrics (b) independent of the other nodes, and (c) at different times relative to the other nodes adding their generated one or more metrics to the relational database, wherein at least one node uses prepared insert statements to add the generated one or more metrics to the relational database.
|