This is an automated email from the ASF dual-hosted git repository.
yhu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from d0014ff38d2 Simplify encoding kw_only args and test init=False args.
(#37231)
add 6a399dff51f Update ChangeStreamDao to query different TVF for
postgresSQL based on (#36667)
No new revisions were added by this update.
Summary of changes:
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 64 ++++-
.../spanner/changestreams/dao/ChangeStreamDao.java | 20 +-
.../gcp/spanner/changestreams/dao/DaoFactory.java | 8 +-
.../gcp/spanner/SpannerIOReadChangeStreamTest.java | 292 ++++++++++++++-------
.../SpannerChangeStreamErrorTest.java | 33 +++
.../changestreams/dao/ChangeStreamDaoTest.java | 97 +++++++
6 files changed, 416 insertions(+), 98 deletions(-)
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/dao/ChangeStreamDaoTest.java
