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 2023/02/10 16:59:21 UTC
[beam] branch master updated (aeb0410d5e5 -> 81f55cb1d48)

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 aeb0410d5e5 Remove ValueProvider from BigtableIO ReadChangeStream (#25409)
     add 81f55cb1d48 Annotate Cloud Bigtable implementation details as Internal (#25403)

No new revisions were added by this update.

Summary of changes:
 .../main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableConfig.java  | 2 ++
 .../beam/sdk/io/gcp/bigtable/changestreams/ByteStringRangeHelper.java  | 2 ++
 .../beam/sdk/io/gcp/bigtable/changestreams/ChangeStreamMetrics.java    | 2 ++
 .../beam/sdk/io/gcp/bigtable/changestreams/ChangeStreamMutation.java   | 3 +++
 .../beam/sdk/io/gcp/bigtable/changestreams/TimestampConverter.java     | 2 ++
 .../beam/sdk/io/gcp/bigtable/changestreams/UniqueIdGenerator.java      | 2 ++
 .../beam/sdk/io/gcp/bigtable/changestreams/action/ActionFactory.java   | 2 ++
 .../sdk/io/gcp/bigtable/changestreams/action/ChangeStreamAction.java   | 2 ++
 .../gcp/bigtable/changestreams/action/DetectNewPartitionsAction.java   | 2 ++
 .../bigtable/changestreams/action/GenerateInitialPartitionsAction.java | 2 ++
 .../bigtable/changestreams/action/ReadChangeStreamPartitionAction.java | 2 ++
 .../beam/sdk/io/gcp/bigtable/changestreams/dao/ChangeStreamDao.java    | 2 ++
 .../apache/beam/sdk/io/gcp/bigtable/changestreams/dao/DaoFactory.java  | 2 ++
 .../sdk/io/gcp/bigtable/changestreams/dao/MetadataTableAdminDao.java   | 2 ++
 .../beam/sdk/io/gcp/bigtable/changestreams/dao/MetadataTableDao.java   | 2 ++
 .../io/gcp/bigtable/changestreams/dofn/DetectNewPartitionsDoFn.java    | 2 ++
 .../beam/sdk/io/gcp/bigtable/changestreams/dofn/InitializeDoFn.java    | 2 ++
 .../gcp/bigtable/changestreams/dofn/ReadChangeStreamPartitionDoFn.java | 2 ++
 .../beam/sdk/io/gcp/bigtable/changestreams/model/PartitionRecord.java  | 2 ++
 .../restriction/ReadChangeStreamPartitionProgressTracker.java          | 2 ++
 .../sdk/io/gcp/bigtable/changestreams/restriction/StreamProgress.java  | 2 ++
 21 files changed, 43 insertions(+)