| CPC G06F 16/23 (2019.01) [G06F 16/16 (2019.01)] | 20 Claims |
|
1. A computer-implemented method executed by data processing hardware that causes the data processing hardware to perform operations comprising:
receiving 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 the respective data in a first buffer associated with a first data streaming application;
storing the respective data in a second buffer associated with a second data streaming application;
transmitting the respective data to the database;
receiving, from the database, confirmation that the respective data of the respective write has been committed to the database, the confirmation comprising 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 confirmation that the respective data of the respective write has been committed to the database:
sending the respective data of the respective write from the first buffer to the first data streaming application based on the order indicator indicating the respective data was committed to the database relative to other writes in the series of writes; and
sending the respective data of the respective write from the second buffer to the second data streaming application based on the order indicator indicating the respective data was committed to the database relative to other writes in the series of writes.
|