Patent ID: 11886439
Assignee: AMAZON TECHNOLOGIES, INC.
Field: Computer technology (Electrical engineering)
Classification: CPC G | IPC G

Claim 0:
1. A system, comprising:
a plurality of head nodes collectively implementing a database system, wherein individual ones of the plurality of head nodes respectively comprise:
at least one processor; and
a memory; and

wherein the database system is configured to:
perform, by the plurality of head nodes, a plurality of different database transactions that update a single database, wherein to perform the plurality of different database transactions, individual ones of the plurality of head nodes of the database system are configured to generate respective transaction logs that describes changes to the single database caused by the performing of the plurality of different database transactions by the plurality of head nodes; and
generate, based at least in part on the generated transaction logs and asynchronous to the performance of the database transactions, a data stream of change indications, wherein to generate the data stream of change indications the database system is configured to:
evaluate, by respective ones of the plurality of head nodes, the respective transaction logs to generate indications of the changes to the single database;
group, in the memory of a primary head node of the plurality of head nodes according to the different database transactions, respective ones of the indications of the changes generated by the plurality of head nodes to generate a plurality of grouped indications of the changes to the single database, wherein individual ones of the plurality of grouped indications of the changes correspond to respective ones of the different database transactions performed by respective head nodes of the plurality of head nodes; and
after a determination that one or more of the different database transactions are committed to the single database, send, from the memory of the primary head node directly to a stream processor external to the single database, the respective grouped indications of the changes of the committed one or more of the different database transactions performed by the plurality of head nodes.