[beam] branch master updated (ea920c52487 -> 1d573e2f880)

[eg...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

egalpin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from ea920c52487 fix distribution example in golang guide (#23567)
     new 03de550a095 BEAM-13592 Add getOrderingKey in org.apache.beam.sdk.io.gcp.pubsub.PubsubMessage
     new d6f5ae47180 Add CHANGES entry
     new 267cd10980f Rename transform name according to review comment
     new bc97c6b9086 Update  to pass ordering key
     new 7be63b94f4d Add CHANGES entry
     new bd1050a7704 Adds ordering key to OutgoingMessage builder, adds new coders to pubsub registrar
     new e2a7c445ef7 Fixes pubsub bounded writer allowing for orderingKey
     new bc60b746a7c Alters order of pubsub message support in registrar
     new 46497d1a2f1 Removed publishTime and messageId in grpc pubsub client publish
     new c3ea5633d71 Attempts to allow different pubsub root url for PubsubIO.Write
     new 92e4d39d4f8 Fixes pubsub tests root url
     new 0d622d9605e Puts PubsubMessageCoder last in registrar
     new 8d502294e91 Uses MoreObjects over Objects
     new fd7deddcbaf Renames PubsubMessageCoder to PubsubMessageWithAttributesAndMessageIdAndOrderingKeyCoder
     new 9ec1429b08f Merge remote-tracking branch 'upstream/master' into egalpin/gemelen-beam-13592-fork
     new 1d573e2f880 Merge pull request #22216 from gemelen/beam-13592-pubsub-java-orderingkey

The 37209 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 CHANGES.md                                         |  1 +
 .../beam/sdk/io/gcp/pubsub/PubsubClient.java       | 10 +++
 .../gcp/pubsub/PubsubCoderProviderRegistrar.java   |  5 +-
 .../beam/sdk/io/gcp/pubsub/PubsubGrpcClient.java   | 17 ++++-
 .../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java    | 52 +++++++++++---
 .../beam/sdk/io/gcp/pubsub/PubsubJsonClient.java   | 16 ++++-
 .../beam/sdk/io/gcp/pubsub/PubsubMessage.java      | 28 ++++++--
 ...AttributesAndMessageIdAndOrderingKeyCoder.java} | 22 ++++--
 .../beam/sdk/io/gcp/pubsub/PubsubMessages.java     | 10 ++-
 .../beam/sdk/io/gcp/pubsub/PubsubTestClient.java   | 40 +++++++++++
 .../sdk/io/gcp/pubsub/PubsubUnboundedSink.java     | 82 ++++++++++++++++++++--
 .../sdk/io/gcp/pubsub/PubsubUnboundedSource.java   | 38 +++++++---
 .../pubsub/PubSubWritePayloadTranslationTest.java  | 12 +++-
 ...ibutesAndMessageIdAndOrderingKeyCoderTest.java} | 10 +--
 .../sdk/io/gcp/pubsub/PubsubUnboundedSinkTest.java | 12 ++--
 15 files changed, 304 insertions(+), 51 deletions(-)
 copy sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/{PubsubMessageWithAttributesAndMessageIdCoder.java => PubsubMessageWithAttributesAndMessageIdAndOrderingKeyCoder.java} (68%)
 copy sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/{PubsubMessageWithAttributesAndMessageIdCoderTest.java => PubsubMessageWithAttributesAndMessageIdAndOrderingKeyCoderTest.java} (87%)