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 9690853b873 Bump golang.org/x/net from 0.49.0 to 0.50.0 in /sdks
(#37558)
add 1164f941f9c Bump filippo.io/edwards25519 from 1.1.0 to 1.1.1 in /sdks
(#37644)
add 41779ad88d3 [Dataflow Streaming] Update windmill timer clasification
logic to work with windmill state tag encoding v2 (#37604)
add 120ceab62a7 Fix renaming of embeddable_to_dict_fn (#37646)
add e41b9b6ba69 runQuickstartJavaFlinkLocal on Flink 2.0 (#37649)
add 872c671b15b Update cibuildwheel dependency (#37504)
add b9d48fa1750 Fix type checking failure with Python 3.10+ union pipe
syntax (int | None) (#37645)
add dfb3f872192 [yaml] : add jinja inheritance example (#37601)
add 59922a390e0 Fix breaking changes from renaming Chunk to EmbeddableItem
(#37651)
add 87c50c67e37 [Python] Support large pipeline options via file (#37379)
No new revisions were added by this update.
Summary of changes:
.../beam_PostCommit_Python_Xlang_Gcp_Direct.json | 2 +-
.github/workflows/build_wheels.yml | 4 +-
.../run_rc_validation_java_quickstart.yml | 2 +-
CHANGES.md | 4 +-
.../bigquery_vector_ingestion_and_search.ipynb | 2 +-
release/build.gradle.kts | 2 +-
.../worker/StreamingModeExecutionContext.java | 34 ++++-----
.../dataflow/worker/WindmillKeyedWorkItem.java | 16 ++--
.../dataflow/worker/WindmillNamespacePrefix.java | 47 ------------
.../dataflow/worker/WindmillTimerInternals.java | 28 +++----
.../runners/dataflow/worker/WindmillTimerType.java | 10 +--
.../worker/windmill/state/WindmillTagEncoding.java | 24 +++---
.../windmill/state/WindmillTagEncodingV1.java | 85 +++++++++++++++-------
.../windmill/state/WindmillTagEncodingV2.java | 42 +++++------
...ractWindmillMap.java => WindmillTimerData.java} | 17 ++++-
.../worker/StreamingGroupAlsoByWindowFnsTest.java | 2 +-
.../dataflow/worker/WindmillKeyedWorkItemTest.java | 2 +-
.../windmill/state/WindmillTagEncodingV1Test.java | 23 +++---
.../windmill/state/WindmillTagEncodingV2Test.java | 61 ++++++++--------
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
.../ml/rag/enrichment/bigquery_vector_search.py | 2 +-
.../apache_beam/ml/rag/ingestion/bigquery.py | 81 ++++++++++++---------
.../ml/rag/ingestion/bigquery_it_test.py | 2 +-
.../apache_beam/runners/worker/sdk_worker_main.py | 27 ++++++-
sdks/python/apache_beam/typehints/typehints.py | 7 +-
.../python/apache_beam/typehints/typehints_test.py | 24 ++++++
.../yaml/examples/testing/examples_test.py | 15 +++-
.../yaml/examples/testing/input_data.py | 5 ++
.../jinja/{include => inheritance}/README.md | 16 +++-
.../base/base_pipeline.yaml} | 40 +++++++---
.../wordCountInheritance.yaml} | 19 ++++-
sdks/python/build.gradle | 3 +-
sdks/python/container/boot.go | 6 +-
34 files changed, 385 insertions(+), 275 deletions(-)
delete mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillNamespacePrefix.java
copy sdks/java/core/src/main/java/org/apache/beam/sdk/util/Weighted.java =>
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillTimerType.java
(80%)
copy
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/{AbstractWindmillMap.java
=> WindmillTimerData.java} (63%)
copy sdks/python/apache_beam/yaml/examples/transforms/jinja/{include =>
inheritance}/README.md (77%)
copy
sdks/python/apache_beam/yaml/examples/transforms/jinja/{include/submodules/mapToFieldsSplitConfig.yaml
=> inheritance/base/base_pipeline.yaml} (53%)
copy
sdks/python/apache_beam/yaml/examples/transforms/jinja/{include/submodules/combineTransform.yaml
=> inheritance/wordCountInheritance.yaml} (69%)
