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 8aba30f Merge pull request #10492: [BEAM-9041, BEAM-9042] SchemaCoder
equals should not rely on from/toRowFunction equality
add 784d18b [BEAM-8932] [BEAM-9036] Revert reverted commit to use
PubsubMessage as the canonical type in beam client (#10474)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 4 +-
.../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 | 38 ++++--
.../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 | 76 +++++++++--
.../sdk/io/gcp/pubsub/PubsubTestClientTest.java | 31 +++--
.../sdk/io/gcp/pubsub/PubsubUnboundedSinkTest.java | 39 ++++--
.../io/gcp/pubsub/PubsubUnboundedSourceTest.java | 28 +++--
17 files changed, 287 insertions(+), 227 deletions(-)
