This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from aa574f5e6e7 Don't use batch interface for single object operations
(#22432)
add a74e6196975 Label kata changes with the language they're modifying
(#22764)
add b1a6cef6c59 [Website] Add GitHub issue link (#22774)
add 6a6acbae272 Fix some typos in the ML doc (#22763)
add 75eb0b1431c Go stateful DoFns user side changes (#22761)
add db474986bf9 fixed column width in tables in Getting started from Spark
guide (#22770)
add 13a03fe2269 Testing authentication for Playground (#22782)
add 9fb4b3f5517 Downgrade bytebuddy version to 1.11.0
add ae034fc9ac6 Merge pull request #22765 from cushon/i22749
add 0ddaf041bd9 [BEAM-12776, fixes #21095] Limit parallel closes from the
prior element to the next element. (#22645)
add 062a0d2d87b [BEAM-13015, #21250] Reuse buffers when possible when
writing on Dataflow streaming hot paths. (#22780)
No new revisions were added by this update.
Summary of changes:
.github/autolabeler.yml | 6 +-
.github/workflows/playground_deploy_examples.yml | 5 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
.../beam/runners/dataflow/worker/PubsubSink.java | 15 +-
.../beam/runners/dataflow/worker/WindmillSink.java | 10 +-
.../dataflow/worker/WindmillStateInternals.java | 2 +-
sdks/go/pkg/beam/core/funcx/fn.go | 45 +++-
sdks/go/pkg/beam/core/funcx/fn_test.go | 16 ++
sdks/go/pkg/beam/core/graph/edge.go | 17 +-
sdks/go/pkg/beam/core/graph/fn.go | 75 +++++-
sdks/go/pkg/beam/core/graph/fn_test.go | 89 ++++--
sdks/go/pkg/beam/core/runtime/exec/fn.go | 32 ++-
sdks/go/pkg/beam/core/runtime/exec/translate.go | 16 ++
sdks/go/pkg/beam/core/runtime/graphx/serialize.go | 5 +
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 24 ++
sdks/go/pkg/beam/core/runtime/graphx/v1/v1.pb.go | 300 +++++++++++----------
sdks/go/pkg/beam/core/runtime/graphx/v1/v1.proto | 2 +
sdks/go/pkg/beam/core/state/state.go | 120 +++++++++
sdks/go/pkg/beam/core/state/state_test.go | 140 ++++++++++
sdks/go/pkg/beam/pardo.go | 13 +
.../java/org/apache/beam/sdk/io/WriteFiles.java | 30 ++-
website/www/site/content/en/contribute/_index.md | 4 +-
.../documentation/sdks/python-machine-learning.md | 8 +-
.../www/site/content/en/get-started/from-spark.md | 101 +++++--
24 files changed, 852 insertions(+), 225 deletions(-)
create mode 100644 sdks/go/pkg/beam/core/state/state.go
create mode 100644 sdks/go/pkg/beam/core/state/state_test.go
