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 2020/09/17 03:00:17 UTC
[beam] tag nightly-master updated (2031203 -> 7c8d90c)
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 2031203 (commit)
to 7c8d90c (commit)
from 2031203 Merge pull request #12818: [BEAM-10875] Support NUMERIC in spanner schema parser
add e0e5fb5 [BEAM-6928] Update changelog with WriteToBigQuery changed requirements.
add 0f9d002 Merge pull request #12845: [BEAM-6928] Update changelog with WriteToBigQuery changed requirements.
add 183e44a [BEAM-10616] Add missing ParDo test cases for streaming/Flink (#12848)
add f216ec3 Bump versions of protobuf, shadow, other gradle plugins. (#12821)
add b981b30 [BEAM-10670] Update Samza to be opt-out for SplittableDoFn.
add aa69ae5 Merge pull request #12617 from lukecwik/beam10670.3
add 001caea [BEAM-7523] Fix starting Kafka container twice in KafkaCSVTableIT (#12847)
add 623ef47 [BEAM-10670] Update Jet runner to be opt-out for splittable DoFn implementation for Read transform.
add 794e7df Update runners/jet/build.gradle
add c8991ba Merge pull request #12616 from lukecwik/beam10670.4
add 0a1ab69 [BEAM-7009] Add Go SDK Standard Coders yaml tests. (#12588)
add 7c8d90c [BEAM-10907] Revert "Deprecate obsolete CombineFn.add_inputs. (#12802)" (#12854)
No new revisions were added by this update.
Summary of changes:
.../job_LoadTests_Combine_Flink_Python.groovy | 2 +-
.../job_LoadTests_ParDo_Flink_Python.groovy | 80 ++-
CHANGES.md | 16 +-
buildSrc/build.gradle | 8 +-
.../beam/model/fnexecution/v1/standard_coders.yaml | 4 +-
.../run_release_candidate_python_mobile_gaming.sh | 1 +
runners/jet/build.gradle | 9 +-
.../org/apache/beam/runners/jet/JetRunner.java | 15 +-
runners/samza/build.gradle | 11 +-
.../org/apache/beam/runners/samza/SamzaRunner.java | 2 +
... => SplittableParDoProcessKeyedElementsOp.java} | 146 +++---
.../samza/translation/ImpulseTranslator.java | 24 +-
.../translation/ParDoBoundMultiTranslator.java | 4 +-
.../samza/translation/SamzaPipelineTranslator.java | 3 +
.../samza/translation/SamzaTransformOverrides.java | 6 +
.../translation/SplittableParDoTranslators.java | 153 ++++++
.../runtime/SamzaStoreStateInternalsTest.java | 26 +-
sdks/go/gogradle.lock | 20 +-
sdks/go/pkg/beam/core/graph/coder/coder.go | 86 ++-
sdks/go/pkg/beam/core/graph/coder/coder_test.go | 21 +
sdks/go/pkg/beam/core/graph/coder/row.go | 4 +-
sdks/go/pkg/beam/core/graph/coder/windows.go | 9 +-
sdks/go/pkg/beam/core/runtime/exec/coder.go | 582 +++++++++++++++++++--
sdks/go/pkg/beam/core/runtime/exec/hash.go | 23 +
sdks/go/pkg/beam/core/runtime/exec/hash_test.go | 5 +-
sdks/go/pkg/beam/core/runtime/graphx/coder.go | 137 ++++-
sdks/go/pkg/beam/core/runtime/graphx/coder_test.go | 14 +
sdks/go/pkg/beam/core/runtime/graphx/dataflow.go | 29 +
.../go/test/regression/coders/fromyaml/fromyaml.go | 420 +++++++++++++++
.../regression/coders/fromyaml/fromyaml_test.go} | 42 +-
.../src/main/java/org/apache/beam/sdk/io/Read.java | 10 +-
.../sql/meta/provider/kafka/KafkaCSVTableIT.java | 7 -
sdks/python/apache_beam/transforms/combiners.py | 10 +-
.../apache_beam/transforms/combiners_test.py | 4 +-
sdks/python/apache_beam/transforms/core.py | 53 +-
sdks/python/apache_beam/transforms/stats.py | 21 +
settings.gradle | 2 +-
37 files changed, 1774 insertions(+), 235 deletions(-)
copy runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/{GroupByKeyOp.java => SplittableParDoProcessKeyedElementsOp.java} (58%)
create mode 100644 runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SplittableParDoTranslators.java
create mode 100644 sdks/go/test/regression/coders/fromyaml/fromyaml.go
copy sdks/go/{pkg/beam/io/filesystem/util.go => test/regression/coders/fromyaml/fromyaml_test.go} (59%)