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 8c90c64836c Merge pull request #25802 Use the cord ctype for proto
generation, where available.
add 2c075b3603f Advance DetectNewPartition's watermark by aggregating the
(#25906)
No new revisions were added by this update.
Summary of changes:
.../changestreams/ByteStringRangeHelper.java | 158 +++++++++++++--------
.../action/DetectNewPartitionsAction.java | 92 ++++++++++++
.../changestreams/dao/MetadataTableDao.java | 40 +++++-
.../changestreams/ByteStringRangeHelperTest.java | 105 ++++++++++++++
.../action/DetectNewPartitionsActionTest.java | 61 ++++++++
.../changestreams/dao/MetadataTableDaoTest.java | 71 +++++++++
6 files changed, 467 insertions(+), 60 deletions(-)
