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 3f474535632 Expose JmsIO read receive timeout (#30485)
add b6301b52058 fix: support reading arrays of structs from bigquery with
schemas (#30448)
add bc1a458bb7c Bigtable: provide a way to override BigtableDataSettings
(#30489)
add 6f5b2197751 Bump cloud.google.com/go/pubsub from 1.34.0 to 1.36.2 in
/sdks (#30465)
add 1c7fb4bc8a0 Fix website precommit (#30540)
add 2a10971fb6b Revert "Add test code to overwrite SQL in Beam Python JDBC
(#30417)" (#30535)
add f0f1cd37dd1 Bigtable: use InstanceBuilder to dynamic load override
class (#30542)
add 8d7adba289b Fix hdfs integration test (#30458)
add 314bd722eea [Python] Vertex AI Feature Store enrichment handler
(#30388)
add 1a05f39883f fix playground backend container builds (#30497)
add 363731ebcb8 Add KafkaIO Stress test (#30467)
add ae9cac3c867 Reduce nullness checks in flink adapters.
add d827f7713e2 spotless again
add 77f9e3a85ee Better preconditions.
add 45d5feaad11 Merge pull request #30488 Reduce nullness checks in flink
adapters.
add e9bcc37556d Moving to 2.56.0-SNAPSHOT on master branch.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 1 +
.github/trigger_files/beam_PostCommit_Python.json | 0
CHANGES.md | 1 +
build.gradle.kts | 3 +-
gradle.properties | 4 +-
it/google-cloud-platform/build.gradle | 3 +-
it/kafka/build.gradle | 6 +
.../java/org/apache/beam/it/kafka/KafkaIOST.java} | 466 ++++++++-------------
playground/backend/containers/java/Dockerfile | 2 +-
playground/backend/containers/python/Dockerfile | 4 +-
.../runners/flink/adapter/BeamAdapterUtils.java | 6 +-
.../flink/adapter/BeamFlinkDataSetAdapter.java | 47 ++-
.../beam/runners/flink/adapter/FlinkInput.java | 2 +-
.../beam/runners/flink/adapter/FlinkOutput.java | 2 +-
sdks/go.mod | 63 ++-
sdks/go.sum | 136 +++---
sdks/go/pkg/beam/core/core.go | 2 +-
.../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 11 +-
.../io/gcp/bigtable/BigtableConfigTranslator.java | 43 +-
.../sdk/io/gcp/bigquery/BigQueryUtilsTest.java | 11 +-
.../gcp/bigtable/BigtableConfigTranslatorTest.java | 116 +++++
.../io/external/xlang_jdbcio_it_test.py | 24 +-
.../io/hdfs_integration_test/docker-compose.yml | 4 +-
sdks/python/apache_beam/transforms/enrichment.py | 6 +-
.../transforms/enrichment_handlers/bigtable.py | 20 +-
.../enrichment_handlers/utils.py} | 23 +-
.../enrichment_handlers/vertex_ai_feature_store.py | 306 ++++++++++++++
.../vertex_ai_feature_store_it_test.py | 287 +++++++++++++
.../vertex_ai_feature_store_test.py | 58 +++
.../vertex_ai_feature_store_tests_requirement.txt | 2 +
sdks/python/apache_beam/version.py | 2 +-
sdks/python/test-suites/direct/common.gradle | 11 +-
sdks/typescript/package.json | 2 +-
.../www/site/content/en/documentation/sdks/yaml.md | 7 +-
34 files changed, 1189 insertions(+), 492 deletions(-)
delete mode 100644 .github/trigger_files/beam_PostCommit_Python.json
copy
it/{google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryIOST.java
=> kafka/src/test/java/org/apache/beam/it/kafka/KafkaIOST.java} (52%)
copy sdks/python/apache_beam/{io/gcp/pubsublite/__init__.py =>
transforms/enrichment_handlers/utils.py} (62%)
create mode 100644
sdks/python/apache_beam/transforms/enrichment_handlers/vertex_ai_feature_store.py
create mode 100644
sdks/python/apache_beam/transforms/enrichment_handlers/vertex_ai_feature_store_it_test.py
create mode 100644
sdks/python/apache_beam/transforms/enrichment_handlers/vertex_ai_feature_store_test.py
copy examples/notebooks/notebook_test_scripts/__init__.py =>
sdks/python/apache_beam/transforms/enrichment_handlers/vertex_ai_feature_store_tests_requirement.txt
(96%)
