Google Inc.

Thomas Robert Magrino

Can Tang

Andrii Shyshkalov

Jack Timothy Dingilian

Yijie Bu

Siu Man Yau

Teng Zhong

Zijie Li

Shitanshu Verma

Douglas Moore Mcerlean

Steven Niemitz

Gary Elliott

A method for change data capture state tracking includes accessing a distributed database including a plurality of clusters, each cluster of the plurality of clusters including a respective plurality of partitions, each cluster of the plurality of clusters configured to receive read and write operation. The method includes receiving, at a second cluster, a plurality of changes for a second table and storing the plurality of changes at a replication log. The method also includes asynchronously replicating the plurality of changes from the second table to a first table and maintaining a respective change stream position tracking a respective position in the replication log indicating one or more changes of the plurality of changes that have been replicated. The method includes receiving a read request at the first cluster requesting one or more rows of the first table and returning the respective change stream position.

Change data capture state tracking for multi-region multi-master noSQL database

A method includes receiving, at a first node of a plurality of nodes of a distributed database, an update request for an aggregate value stored at the first node. The update request includes a first sequencer. Based on receiving the update request for the aggregate value, the method includes updating the aggregate value based on the update request, storing a log record of the update to a changelog, and transmitting the update request to each other node. After updating the aggregate value, the method includes receiving, from a second node, a reset request for the aggregate value. The reset request includes a second sequencer. The method includes determining that the reset request predates the update request. Based on determining that the reset request predates the update request, the method includes resetting the aggregate value and updating the aggregate value based on the update request.

Distributed aggregations in bigtable

Growing community of inventors

Mamaroneck, NY, United States of America

Thomas Robert Magrino