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 e5298318a11 Fix link in `basics` (#23399)
add abb932e97ab Add brief descriptions about end-to-end ML Pipelines
(#23880)
add 1e72e60b5d4 Disable `optimizeOuterThis` when building with JDK > 8
(#23902)
add 2d319316282 Fix Beam Sql does not support CHAR, VARCHAR, BINARY,
VARBINARY
add 1cc5e4ba433 Remove debug leftover
add a443df127a9 Merge pull request #23891: Fix Beam Sql Calcite Util does
not support CHAR, VARCHAR, BINARY, VARBINARY
add 9f33da1f3f1 [Playground] [Backend] Update playground cache component
to increase fault tolerance (#23461)
add d4fd174917d Upgrade Akvelon editor (#23415) (#23900)
add e808182d7b8 [Website] update additional case studies layout and scss
(#23555)
add 68aee2f7889 [Website] add shuffle to logos (#23847)
add 0fbe0a79a2c Clean-up DatastoreV1.java (#23892)
add 3371a1c187f Add LogElements as a Beam PTransform (#23879)
add f46382110d7 Fix incorrect object size calculation in StateCache
(#23000) (#23886)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 20 +++-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 3 +
.../Common Transforms/Aggregation/Count/task.py | 4 +-
.../Common Transforms/Aggregation/Largest/task.py | 4 +-
.../Common Transforms/Aggregation/Mean/task.py | 4 +-
.../Common Transforms/Aggregation/Smallest/task.py | 4 +-
.../Common Transforms/Aggregation/Sum/task.py | 4 +-
.../python/Common Transforms/Filter/Filter/task.py | 4 +-
.../python/Common Transforms/Filter/ParDo/task.py | 4 +-
.../Common Transforms/WithKeys/WithKeys/task.py | 4 +-
.../Core Transforms/Branching/Branching/task.py | 6 +-
.../CoGroupByKey/CoGroupByKey/task.py | 4 +-
.../Core Transforms/Combine/Combine PerKey/task.py | 4 +-
.../Core Transforms/Combine/CombineFn/task.py | 4 +-
.../Combine/Simple Function/task.py | 4 +-
.../Composite Transform/task.py | 4 +-
.../python/Core Transforms/Flatten/Flatten/task.py | 4 +-
.../Core Transforms/GroupByKey/GroupByKey/task.py | 4 +-
.../python/Core Transforms/Map/FlatMap/task.py | 4 +-
.../katas/python/Core Transforms/Map/Map/task.py | 4 +-
.../Core Transforms/Map/ParDo OneToMany/task.py | 4 +-
.../katas/python/Core Transforms/Map/ParDo/task.py | 4 +-
.../Core Transforms/Partition/Partition/task.py | 6 +-
.../Core Transforms/Side Input/Side Input/task.py | 4 +-
.../Side Output/Side Output/task.py | 6 +-
.../python/Examples/Word Count/Word Count/task.py | 4 +-
.../katas/python/IO/TextIO/ReadFromText/task.py | 4 +-
.../Introduction/Hello Beam/Hello Beam/task.py | 4 +-
.../Streaming/Timestamps/Add Timestamps/task.py | 4 +-
.../Streaming/Triggers/Early Triggers/task.py | 2 +-
.../Streaming/Triggers/Event Time Triggers/task.py | 2 +-
.../Triggers/Window Accumulation Modes/task.py | 2 +-
.../python/Streaming/Windows/Fixed Windows/task.py | 4 +-
learning/katas/python/log_elements.py | 54 ---------
playground/backend/README.md | 1 +
playground/backend/cmd/server/controller.go | 6 +-
playground/backend/containers/python/Dockerfile | 1 -
.../backend/internal/components/cache_component.go | 128 +++++++++++++--------
.../internal/components/cache_component_test.go | 8 +-
.../internal/db/mapper/datastore_mapper_test.go | 2 +-
.../db/schema/migration/migrations_test.go | 2 +-
.../backend/internal/environment/application.go | 11 +-
.../internal/environment/environment_service.go | 36 +++---
.../environment/environment_service_test.go | 14 +--
.../lib/src/controllers/playground_controller.dart | 48 ++++----
.../controllers/snippet_editing_controller.dart | 11 +-
.../frontend/playground_components/pubspec.yaml | 2 +-
playground/frontend/pubspec.lock | 2 +-
.../sdk/extensions/sql/impl/rel/BeamCalcRel.java | 25 +++-
.../extensions/sql/impl/utils/CalciteUtils.java | 7 ++
.../sdk/extensions/sql/BeamComplexTypeTest.java | 107 ++++++++++++-----
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 8 +-
.../apache_beam/runners/worker/statecache.py | 3 +-
.../apache_beam/runners/worker/statecache_test.py | 51 ++++++++
sdks/python/apache_beam/transforms/util.py | 44 +++++++
sdks/python/apache_beam/transforms/util_test.py | 42 +++++++
...hor-content-jump-fix.js => shuffle-elements.js} | 14 ++-
website/www/site/assets/scss/_case_study.scss | 9 ++
.../www/site/content/en/case-studies/akvelon.md | 2 +-
.../site/content/en/documentation/ml/overview.md | 6 +-
website/www/site/layouts/case-studies/list.html | 26 +++--
61 files changed, 510 insertions(+), 307 deletions(-)
delete mode 100644 learning/katas/python/log_elements.py
copy website/www/site/assets/js/{anchor-content-jump-fix.js =>
shuffle-elements.js} (61%)
