| CPC G06F 16/23 (2019.01) [G06F 16/16 (2019.01)] | 20 Claims |
|
1. A computer-implemented method comprising:
receiving, by data processing hardware, a series of writes, each write in the series of writes requesting respective data to be stored at a database in communication with the data processing hardware; and
for each respective write in the series of writes:
storing, by the data processing hardware, the respective data in a buffer associated with one or more data streaming applications;
transmitting, by the data processing hardware, the respective data to the database;
receiving, by the data processing hardware and from the database, an order indicator indicating an order the respective data of the respective write was committed to the database relative to other writes in the series of writes; and
in response to receiving the order indicator, sending, by the data processing hardware, the respective data of the respective write from the buffer to each data streaming application of the one or more data streaming applications based on the order indicator indicating the order the respective data was committed to the database relative to other writes in the series of writes.
|