You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2019/08/30 21:55:50 UTC
[beam] branch master updated (9bbd89a -> a9e14ff)

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

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


    from 9bbd89a  Merge pull request #9440: [BEAM-5428] Modify cache token Proto design to only include tokens in ProcessBundleRequest
     add f1d02e9  [BEAM-3489] add PubSub messageId to PubsubMessage
     add 71f6ddf  [BEAM-3489] add Coder test
     add d0b9cac  [BEAM-3489] add messageId coders to PubsubUnboundedSource.getOutputCoder()
     add b8313b0  [BEAM-3489] update docs
     add a9e14ff  [BEAM-3489] add PubSub messageId in PubsubMessage

No new revisions were added by this update.

Summary of changes:
 .../beam/runners/dataflow/DataflowRunner.java      | 10 +--
 .../beam/runners/dataflow/worker/PubsubReader.java |  4 +-
 .../gcp/pubsub/PubsubCoderProviderRegistrar.java   |  7 +-
 .../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java    | 47 ++++++++++++-
 .../beam/sdk/io/gcp/pubsub/PubsubMessage.java      | 18 ++++-
 ...subMessageWithAttributesAndMessageIdCoder.java} | 30 ++++-----
 ...r.java => PubsubMessageWithMessageIdCoder.java} | 32 +++++----
 .../sdk/io/gcp/pubsub/PubsubUnboundedSource.java   | 78 +++++++++++++++++++---
 .../beam/sdk/io/gcp/pubsub/TestPubsubSignal.java   |  2 +-
 .../pubsub/PubsubMessagePayloadOnlyCoderTest.java} | 35 ++++++----
 ...MessageWithAttributesAndMessageIdCoderTest.java | 62 +++++++++++++++++
 .../PubsubMessageWithAttributesCoderTest.java      | 60 +++++++++++++++++
 .../PubsubMessageWithMessageIdCoderTest.java}      | 36 ++++++----
 .../beam/sdk/io/gcp/pubsub/PubsubReadIT.java       | 47 +++++++++++++
 14 files changed, 388 insertions(+), 80 deletions(-)
 copy sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/{PubsubMessageWithAttributesCoder.java => PubsubMessageWithAttributesAndMessageIdCoder.java} (73%)
 copy sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/{PubsubMessagePayloadOnlyCoder.java => PubsubMessageWithMessageIdCoder.java} (64%)
 copy sdks/java/{core/src/test/java/org/apache/beam/sdk/coders/VoidCoderTest.java => io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessagePayloadOnlyCoderTest.java} (51%)
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessageWithAttributesAndMessageIdCoderTest.java
 create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessageWithAttributesCoderTest.java
 copy sdks/java/{core/src/test/java/org/apache/beam/sdk/coders/VoidCoderTest.java => io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessageWithMessageIdCoderTest.java} (50%)