This is an automated email from the ASF dual-hosted git repository.
boyuanz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 1d98dc1 [BEAM-9026] Clean up RuntimeValueProvider.runtime_options
(#10457)
add 8945f3f Modify PubsubClient to use the proto message throughout.
add 234d4f1 [BEAM-8932] Modify PubsubClient to use the proto message
throughout.
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 6 +-
.../beam/sdk/io/gcp/pubsub/PubsubClient.java | 139 +++++----------------
.../beam/sdk/io/gcp/pubsub/PubsubGrpcClient.java | 29 ++---
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 9 +-
.../beam/sdk/io/gcp/pubsub/PubsubJsonClient.java | 28 +++--
.../beam/sdk/io/gcp/pubsub/PubsubTestClient.java | 11 +-
.../sdk/io/gcp/pubsub/PubsubUnboundedSink.java | 23 ++--
.../sdk/io/gcp/pubsub/PubsubUnboundedSource.java | 33 ++---
.../apache/beam/sdk/io/gcp/pubsub/TestPubsub.java | 20 ++-
.../beam/sdk/io/gcp/pubsub/TestPubsubSignal.java | 6 +-
.../apache/beam/sdk/io/gcp/GcpApiSurfaceTest.java | 1 +
.../sdk/io/gcp/pubsub/PubsubGrpcClientTest.java | 19 +--
.../beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 8 +-
.../sdk/io/gcp/pubsub/PubsubJsonClientTest.java | 46 +++++--
.../sdk/io/gcp/pubsub/PubsubTestClientTest.java | 31 +++--
.../sdk/io/gcp/pubsub/PubsubUnboundedSinkTest.java | 39 ++++--
.../io/gcp/pubsub/PubsubUnboundedSourceTest.java | 28 +++--
17 files changed, 250 insertions(+), 226 deletions(-)
