-
Notifications
You must be signed in to change notification settings - Fork 1.3k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
feat(bigtable/bttest): Implement change streams #9203
base: main
Are you sure you want to change the base?
Conversation
This is an important semantic property of BigTable: "All mutations in a single write request have the same timestamp unless you override them." https://cloud.google.com/bigtable/docs/writes#write-types
Implement the GenerateInitialChangeStreamPartitions and ReadChangeStream BigtableServer methods, and record and serve change streams for tables that are created with a ChangeStreamConfig specified. Note: this change does not implement sending Heartbeat records from ReadChangeStream, and the retention period specified by the client is not honored. These are left as TODOs.
I'm not sure why those conformance tests are failing. Any pointers? |
The conformance tests were added in failed state. Their failures can be ignored |
What is the bug related to commit times? |
@bhshkh to quote the commit message:
|
Our use-case for this is that we have a service that uses change streams and we want to be able to test it locally. |
@adg , can you please sign the CLA to merge the PR. please visit https://cla.developers.google.com/ |
@adg can you please sign the CLA if you would still like these changes, or else we can close this PR if you are no longer interested. |
These changes add an implementation of the GenerateInitialChangeStreamPartitions and ReadChangeStream BigtableServer methods to the bttest package, and also fix a bug related to commit times.