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%)