beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From boyu...@apache.org
Subject [beam] branch master updated (8aba30f -> 784d18b)
Date Wed, 08 Jan 2020 02:49:35 GMT
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(-)


Mime
View raw message