nancyxu123 opened a new pull request, #24390: URL: https://github.com/apache/beam/pull/24390
Support Postgres databases for the SpannerIO change stream connector. The connector should be able to query when (1) both the metadata database and the change streams database are GSQL (2) when both the metadata database and the change streams database are Postgres (3) when the metadata database is in Postgres and the change streams database is in GSQL and (4) when the metadata database is in GSQL and the change streams database is in Postgres This PR first does an initial lookup to determine whether or not the change streams database and the metadata database are Postgres in SpannerIO. Then, it makes different queries to the metadata table and to the change stream depending on whether or not the database is postgres. It also creates the metadata table differently depending on whether the metadata database is Postgres. Finally, it maps received records into ChangeStreamRecords differently depending on whether or not the change stream is in a Postgres database or not. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
