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