This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 40382c84130 BigQueryHelpers: log statuses using PrettyString (#26037)
add 9c52e0594d6 Make DetectNewPartitions handle Splits and Merges (#25997)
No new revisions were added by this update.
Summary of changes:
.../changestreams/ByteStringRangeHelper.java | 99 +++++++++----
.../ChangeStreamContinuationTokenHelper.java | 47 ++++++
.../changestreams/ChangeStreamMetrics.java | 36 +++++
.../action/DetectNewPartitionsAction.java | 158 ++++++++++++++++++++-
.../action/ReadChangeStreamPartitionAction.java | 35 +++--
.../changestreams/dao/MetadataTableDao.java | 40 +++++-
.../changestreams/ByteStringRangeHelperTest.java | 93 ++++++++++++
.../ChangeStreamContinuationTokenHelperTest.java | 68 +++++++++
.../action/DetectNewPartitionsActionTest.java | 157 ++++++++++++++++++++
.../ReadChangeStreamPartitionActionTest.java | 89 +++++++++++-
.../changestreams/dao/MetadataTableDaoTest.java | 4 +-
11 files changed, 778 insertions(+), 48 deletions(-)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/ChangeStreamContinuationTokenHelper.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/ChangeStreamContinuationTokenHelperTest.java
