Combinators

A computer program product for managing a distributed database system, the computer program product comprising a computer readable storage medium having program instructions embodied therewith, wherein the computer readable storage medium is not a transitory signal per se, the program instructions executable by a processor to cause the processor to perform a method comprising:

• storing, by the processor, programs to be executed by a distributed database system having three or more nodes each with processors and memory;
• at a first node of the distributed database system, receiving, by the processor, from one or more caller nodes of the distributed database system an N number of service tasks to add to a value in a row stored in the distributed database system at a write daemon;
• recording, by the processor, a time of receipt of the N number of service tasks;
• combining, by the processor, the N number of service tasks to a single row in the distributed database system at the write daemon;
• and
• reducing, by the processor, a number of service tasks to attend to the N number of requests by sending the N number of requests to at least two other bucket daemons on at least two other nodes of the distributed database system that combine the N number of service tasks and executing the reduced number of service tasks in accordance with an order associated with the recorded time of receipt.

A system, comprising:

• a processor and logic integrated with and/or executable by the processor, the logic being configured to:
• store programs to be executed by a distributed database system having three or more nodes each with processors and memory;
• at a first node of the distributed database system, receive from one or more caller nodes of the distributed database system an N number of service tasks to add to a value in a row stored in the distributed database system at a write daemon;
• record a time of receipt of the N number of service tasks;
• combine the N number of service tasks to a single row in the distributed database system at the write daemon;
• and
• reduce a number of service tasks to attend to the N number of requests by sending the N number of requests to at least two other bucket daemons on at least two other nodes of the distributed database system that combine the N number of service tasks and executing the reduced number of service tasks in accordance with an order associated with the recorded time of receipt.