You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2021/01/19 04:20:12 UTC

[beam] tag nightly-master updated (d0b6fdf -> e748846)

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

github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.


*** WARNING: tag nightly-master was modified! ***

    from d0b6fdf  (commit)
      to e748846  (commit)
    from d0b6fdf  Merge pull request #13716: [BEAM-11594] Upgrade gradle to version 6.8
     add d1de1ab  [BEAM-11538] Add a Deque Encoder
     add f437145  Merge pull request #13635: [BEAM-11538] Add a Deque Encoder
     add f5c87dc  [BEAM-11593] Move SparkStructuredStreamingRunnerRegistrar to its own package
     add 8054866  Merge pull request #13715: [BEAM-11593] Move SparkStructuredStreamingRunnerRegistrar to its own package
     add e748846  Fix typo in universal.go (#13766)

No new revisions were added by this update.

Summary of changes:
 CHANGES.md                                         |  1 +
 .../beam/runners/spark/SparkRunnerRegistrar.java   |  9 +---
 .../SparkStructuredStreamingRunnerRegistrar.java}  | 18 ++++----
 .../runners/spark/SparkRunnerRegistrarTest.java    | 10 +----
 ...arkStructuredStreamingRunnerRegistrarTest.java} | 27 ++++++------
 sdks/go/pkg/beam/runners/universal/universal.go    |  4 +-
 .../sdk/coders/{ListCoder.java => DequeCoder.java} | 34 ++++++++-------
 .../apache/beam/sdk/testing/CoderProperties.java   | 29 +++++++++++++
 .../org/apache/beam/sdk/transforms/Create.java     |  4 ++
 .../{SetCoderTest.java => DequeCoderTest.java}     | 50 +++++++++++++++-------
 10 files changed, 114 insertions(+), 72 deletions(-)
 copy runners/{jet/src/main/java/org/apache/beam/runners/jet/JetRunnerRegistrar.java => spark/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingRunnerRegistrar.java} (74%)
 copy runners/{google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowPipelineRegistrarTest.java => spark/src/test/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingRunnerRegistrarTest.java} (67%)
 copy sdks/java/core/src/main/java/org/apache/beam/sdk/coders/{ListCoder.java => DequeCoder.java} (62%)
 copy sdks/java/core/src/test/java/org/apache/beam/sdk/coders/{SetCoderTest.java => DequeCoderTest.java} (60%)