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 e4a0208534c Merge pull request #31662 from apache/aaltay-patch-1
add c6c3fd0490a Handle MultimapKeysSideInput in State GetRequests (#31632)
add 3914ad0754d Solace Read connector: data classes and mapper (#31637)
add 999b70b0c48 Bump github.com/linkedin/goavro/v2 from 2.12.0 to 2.13.0
in /sdks (#31633)
add 3695d496701 Bump golang.org/x/net from 0.24.0 to 0.26.0 in /sdks
(#31614)
add 14fd366f0ad Add support for sharing models across steps (#31665)
add 18af8c837fa Solace Read connector (#31476)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 2 +-
sdks/go.mod | 16 +-
sdks/go.sum | 32 +-
.../beam/runners/prism/internal/worker/worker.go | 15 +
.../runners/prism/internal/worker/worker_test.go | 95 +++
sdks/java/io/solace/build.gradle | 9 +
.../org/apache/beam/sdk/io/solace/SolaceIO.java | 415 ++++++++++--
.../io/solace/broker/SessionServiceFactory.java | 19 +
.../org/apache/beam/sdk/io/solace/data/Solace.java | 323 +++++++++-
.../sdk/io/solace/MockEmptySessionService.java} | 28 +-
.../apache/beam/sdk/io/solace/MockSempClient.java | 87 +++
.../beam/sdk/io/solace/MockSempClientFactory.java} | 22 +-
.../beam/sdk/io/solace/MockSessionService.java | 88 +++
.../sdk/io/solace/MockSessionServiceFactory.java} | 34 +-
.../apache/beam/sdk/io/solace/SolaceIOTest.java | 597 +++++++++++++++++
.../beam/sdk/io/solace/data/SolaceDataUtils.java | 708 +++++++++++++++++++++
sdks/python/apache_beam/ml/inference/base.py | 15 +-
sdks/python/apache_beam/ml/inference/base_test.py | 39 ++
18 files changed, 2423 insertions(+), 121 deletions(-)
copy
sdks/java/{extensions/euphoria/src/test/java/org/apache/beam/sdk/extensions/euphoria/core/testkit/accumulators/LongCounter.java
=>
io/solace/src/test/java/org/apache/beam/sdk/io/solace/MockEmptySessionService.java}
(56%)
create mode 100644
sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/MockSempClient.java
copy
sdks/java/io/solace/src/{main/java/org/apache/beam/sdk/io/solace/package-info.java
=> test/java/org/apache/beam/sdk/io/solace/MockSempClientFactory.java} (62%)
create mode 100644
sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/MockSessionService.java
copy sdks/java/{core/src/main/java/org/apache/beam/sdk/state/ValueState.java
=>
io/solace/src/test/java/org/apache/beam/sdk/io/solace/MockSessionServiceFactory.java}
(61%)
create mode 100644
sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/SolaceIOTest.java
create mode 100644
sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/data/SolaceDataUtils.java
