You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pa...@apache.org on 2022/02/01 19:57:39 UTC
[beam] branch master updated (59b0b2a -> 53ba580)
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 59b0b2a [BEAM-13760] Add random component to default python dataflow job name (#16641)
add 53ba580 Merge pull request #16655 from [BEAM-12164]: Add retry protection to DetectNewPartitions
No new revisions were added by this update.
Summary of changes:
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 2 +-
.../changestreams/action/ActionFactory.java | 26 +++
.../action/DetectNewPartitionsAction.java | 211 +++++++++++++++++++++
.../changestreams/dao/PartitionMetadataDao.java | 86 ++++-----
.../dofn/DetectNewPartitionsDoFn.java | 174 +++--------------
5 files changed, 310 insertions(+), 189 deletions(-)
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/action/DetectNewPartitionsAction.java