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 2025/02/26 03:53:11 UTC

(beam) branch nightly-refs/heads/master updated (f0cc9b6b24f -> 7644a824da7)

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 f0cc9b6b24f Merge pull request #34044 Avoid missing hashlib.file_digest for Python < 3.11.
     add 87f0ed385bc add equals/hashCode to debezium offsetHolder to avoid coder warning (#34036)
     add 16f7bb613a6 Change UnboundedSourceAsSdfWrapperFn to share the cache across instances. (#33901)
     add 2a400d4c156 Fix io name (#34065)
     add 5d9ba3703f3 [AnomalyDetection] Add threshold and aggregation functions. (#34018)
     add cbe91f06cbc Fix update all fields by default in AlloyDB conflict resolution. (#34066)
     add 1d2b9c53884 Pass extra write args from AlloyDB writer to WriteToJdbc. (#34067)
     add 0dba719989b Add ExtractWindowingInfo transform.
     add 8534f2570c3 Add default and iterable syntactic sugar.
     add b98e331b3ec Docstring cleanup.
     add 911a3becdf4 Make mypy happy.
     add 86795a0a94d Add a yaml windowing info extraction example.
     add 82d3d8ddef0 Merge pull request #34051 Add an ExtractWindowingInfo transform.
     add 170885af558 Bump target for Republish Released Docker Containers to 2.63.0 RC2 (#34068)
     add 7034e505328 Add info on protobuf dependency (#34069)
     add d0f288bcae7 Bump github.com/tetratelabs/wazero from 1.8.2 to 1.9.0 in /sdks (#34032)
     add b1f6b0ac6e8 reverse order (#33900)
     add d436d02d775 Preempt issubclass error for generic types (#33995)
     add 6b8e860187e Add support for collections.abc.Sequence (#33999)
     add 9aee5d8ec09 Refactor markdown to html rendering for re-use.
     add 724d448eea9 Add examples file generation.
     add a365031eff2 A bit of cleanup in the example files.
     add 21fc93b2c26 Add header and backlink to examples file.
     add 7644a824da7 Merge pull request #34050 Create a listing of YAML examples for the docs.

No new revisions were added by this update.

Summary of changes:
 .../republish_released_docker_containers.yml       |   4 +-
 contributor-docs/java-dependency-upgrades.md       |  11 +
 sdks/go.mod                                        |   2 +-
 sdks/go.sum                                        |   4 +-
 .../src/main/java/org/apache/beam/sdk/io/Read.java |  63 ++--
 ...oizingPerInstantiationSerializableSupplier.java |  60 ++++
 .../test/java/org/apache/beam/sdk/io/ReadTest.java |   7 +-
 ...ngPerInstantiationSerializableSupplierTest.java | 130 ++++++++
 .../beam/io/debezium/KafkaSourceConsumerFn.java    |  78 ++++-
 .../io/debezium/KafkaSourceConsumerFnTest.java     |  56 +++-
 sdks/python/apache_beam/coders/coders.py           |   4 +-
 sdks/python/apache_beam/ml/anomaly/aggregations.py | 324 +++++++++++++++++++
 .../apache_beam/ml/anomaly/aggregations_test.py    | 159 ++++++++++
 sdks/python/apache_beam/ml/anomaly/base.py         |  19 +-
 sdks/python/apache_beam/ml/anomaly/base_test.py    |  11 +-
 .../apache_beam/ml/anomaly/specifiable_test.py     |  20 +-
 sdks/python/apache_beam/ml/anomaly/thresholds.py   | 343 +++++++++++++++++++++
 .../apache_beam/ml/anomaly/thresholds_test.py      | 235 ++++++++++++++
 .../python/apache_beam/ml/rag/ingestion/alloydb.py |  13 +-
 .../ml/rag/ingestion/alloydb_it_test.py            | 111 +++++++
 sdks/python/apache_beam/transforms/stats.py        |   2 +-
 .../typehints/native_type_compatibility.py         |  11 +
 .../typehints/native_type_compatibility_test.py    |   8 +
 sdks/python/apache_beam/typehints/typehints.py     |  44 +++
 .../python/apache_beam/typehints/typehints_test.py |  26 ++
 .../apache_beam/yaml/examples/regex_matches.yaml   |   6 +-
 .../apache_beam/yaml/examples/simple_filter.yaml   |   3 +-
 .../yaml/examples/simple_filter_and_combine.yaml   |   3 +-
 .../aggregation/combine_sum_windowed.yaml          |  92 ++++++
 .../yaml/examples/wordcount_minimal.yaml           |   7 +-
 sdks/python/apache_beam/yaml/generate_yaml_docs.py | 169 +++++++---
 sdks/python/apache_beam/yaml/yaml_mapping.py       | 107 +++++++
 sdks/python/apache_beam/yaml/yaml_mapping_test.py  |  94 ++++++
 .../site/content/en/performance/bigtable/_index.md |  12 +-
 34 files changed, 2110 insertions(+), 128 deletions(-)
 create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/util/MemoizingPerInstantiationSerializableSupplier.java
 create mode 100644 sdks/java/core/src/test/java/org/apache/beam/sdk/util/MemoizingPerInstantiationSerializableSupplierTest.java
 create mode 100644 sdks/python/apache_beam/ml/anomaly/aggregations.py
 create mode 100644 sdks/python/apache_beam/ml/anomaly/aggregations_test.py
 create mode 100644 sdks/python/apache_beam/ml/anomaly/thresholds.py
 create mode 100644 sdks/python/apache_beam/ml/anomaly/thresholds_test.py
 create mode 100644 sdks/python/apache_beam/yaml/examples/transforms/aggregation/combine_sum_windowed.yaml