You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ud...@apache.org on 2021/10/01 18:34:41 UTC

[beam] 01/01: Merge pull request #15629 from apache/revert-15608-dpcollins-cherry-pick

This is an automated email from the ASF dual-hosted git repository.

udim pushed a commit to branch release-2.33.0
in repository https://gitbox.apache.org/repos/asf/beam.git

commit d916c1f55e57a61b54135d0922ad8660735bd287
Merge: 1816cf4 bb5ecd1
Author: Udi Meiri <ud...@users.noreply.github.com>
AuthorDate: Fri Oct 1 11:33:47 2021 -0700

    Merge pull request #15629 from apache/revert-15608-dpcollins-cherry-pick

 .../org/apache/beam/gradle/BeamModulePlugin.groovy |   2 +-
 .../beam/sdk/io/gcp/pubsub/PubsubMessages.java     |  42 ++--
 .../sdk/io/gcp/pubsublite/CloudPubsubChecks.java   |  51 ++++
 .../io/gcp/pubsublite/CloudPubsubTransforms.java   | 104 --------
 .../pubsublite/ManagedBacklogReaderFactory.java    |  33 ---
 .../ManagedBacklogReaderFactoryImpl.java           |  68 -----
 .../sdk/io/gcp/pubsublite/OffsetByteRange.java     |  38 ---
 .../io/gcp/pubsublite/OffsetByteRangeCoder.java    |  63 -----
 .../io/gcp/pubsublite/OffsetByteRangeTracker.java  |  66 ++---
 .../io/gcp/pubsublite/PerServerPublisherCache.java |   4 -
 .../pubsublite/PerSubscriptionPartitionSdf.java    |  57 ++---
 .../beam/sdk/io/gcp/pubsublite/PublisherCache.java |  62 ++---
 .../beam/sdk/io/gcp/pubsublite/Publishers.java     |  72 ++----
 .../beam/sdk/io/gcp/pubsublite/PubsubLiteIO.java   |   2 +-
 .../beam/sdk/io/gcp/pubsublite/PubsubLiteSink.java |  10 +-
 .../sdk/io/gcp/pubsublite/SubscribeTransform.java  |  44 ++--
 .../sdk/io/gcp/pubsublite/SubscriberOptions.java   |  26 +-
 .../SubscriptionPartitionProcessorFactory.java     |   3 +-
 .../SubscriptionPartitionProcessorImpl.java        |  23 +-
 .../gcp/pubsublite/TopicBacklogReaderSettings.java |   6 +-
 .../sdk/io/gcp/pubsublite/TrackerWithProgress.java |  24 --
 .../gcp/pubsublite/OffsetByteRangeTrackerTest.java |  34 +--
 .../PerSubscriptionPartitionSdfTest.java           |  70 +-----
 .../beam/sdk/io/gcp/pubsublite/ReadWriteIT.java    | 280 ---------------------
 .../SubscriptionPartitionProcessorImplTest.java    |  49 ++--
 25 files changed, 297 insertions(+), 936 deletions(-)