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 0e212782d02 Update republish_released_docker_containers.yml (#34936)
add 41d70211c81 Refactor: separate PairWithRestriction from FnApiDoFnRunner
add f258f0cb11f Merge pull request #34883: Refactor: separate
PairWithRestriction from FnApiDoFnRunner
add ee72f5e1849 Allow psycopg2 2.9.10 (#34893)
add 51f77637c9c Add 2.63 breaking incompatibility to CHANGES.md (#34931)
add 25525b4d276 Bump golang.org/x/net from 0.39.0 to 0.40.0 in /sdks
(#34885)
add 046b1b25787 Bump github.com/testcontainers/testcontainers-go in /sdks
(#34815)
add 5f4efb10490 Correctly auto-enable prism for some pipelines (#34921)
add 9ab508755f4 Fix gcs audit custom entries (#34942)
add 8f0c36bdec5 Refactor: share common FnApiStateAccessor creation logic
add 1de0d1f642d Merge pull request #34907: Share FnApiStateAccessor
initialization across ParDo runners in Java SDK harness
add acca8c4f7f4 Change HF inference default api url (#34944)
add ed1ef555116 Make the connector placement table ParentTokens column
nullable. (#34812)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 2 +
sdks/go.mod | 10 +-
sdks/go.sum | 24 +-
sdks/java/harness/build.gradle | 1 +
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 160 +-----
.../SplittablePairWithRestrictionDoFnRunner.java | 325 ++++++++++++
.../beam/fn/harness/state/FnApiStateAccessor.java | 167 ++++++-
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 551 ---------------------
.../NonWindowObservingTestSplittableDoFn.java | 201 ++++++++
...plittablePairWithRestrictionDoFnRunnerTest.java | 550 ++++++++++++++++++++
.../harness/WindowObservingTestSplittableDoFn.java | 107 ++++
.../dao/PartitionMetadataAdminDao.java | 4 +-
.../spanner/changestreams/dofn/InitializeDoFn.java | 1 -
.../mapper/PartitionMetadataMapper.java | 5 +-
.../changestreams/model/InitialPartition.java | 5 -
.../changestreams/model/PartitionMetadata.java | 11 +-
.../changestreams/model/PartitionMetadataTest.java | 17 -
.../ml/transforms/embeddings/huggingface.py | 2 +-
.../python/apache_beam/options/pipeline_options.py | 10 +-
.../apache_beam/options/pipeline_options_test.py | 14 +
.../apache_beam/runners/direct/direct_runner.py | 3 +-
sdks/python/setup.py | 43 +-
22 files changed, 1441 insertions(+), 772 deletions(-)
create mode 100644
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/SplittablePairWithRestrictionDoFnRunner.java
create mode 100644
sdks/java/harness/src/test/java/org/apache/beam/fn/harness/NonWindowObservingTestSplittableDoFn.java
create mode 100644
sdks/java/harness/src/test/java/org/apache/beam/fn/harness/SplittablePairWithRestrictionDoFnRunnerTest.java
create mode 100644
sdks/java/harness/src/test/java/org/apache/beam/fn/harness/WindowObservingTestSplittableDoFn.java
