This is an automated email from the ASF dual-hosted git repository.
altay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 1e59484 Merge pull request #13127 from
kennknowles/gauge-metrics-dataflow
add 3591151 [BEAM-10114] Upgrade version of pubsublite to 0.4.1. (#12957)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
.../io/gcp/pubsublite/BufferingPullSubscriber.java | 116 -------------
.../beam/sdk/io/gcp/pubsublite/PubsubLiteIO.java | 12 +-
.../gcp/pubsublite/PubsubLiteUnboundedReader.java | 3 +-
.../gcp/pubsublite/PubsubLiteUnboundedSource.java | 19 ++-
...scriber.java => TranslatingPullSubscriber.java} | 28 +++-
.../pubsublite/BufferingPullSubscriberTest.java | 183 ---------------------
.../sdk/io/gcp/pubsublite/PubsubLiteSinkTest.java | 10 +-
.../pubsublite/PubsubLiteUnboundedReaderTest.java | 5 +-
9 files changed, 54 insertions(+), 324 deletions(-)
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/BufferingPullSubscriber.java
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{PullSubscriber.java
=> TranslatingPullSubscriber.java} (51%)
delete mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/BufferingPullSubscriberTest.java
