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(-)