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 d93f93abf0e Fix backlog reported by periodicsequence in python and go
sdks to not include future outputs (#32513)
add faf884a7a1b Update Python Inference Benchmark Test to Python 3.10
(#32550)
add e3c6f4747be Add RowStringInterpolator utility (#32367)
add 01c7caf92af SolaceIO: deduplicate records in the integration test
(#32557)
add 380ed7b7f74 fix: add topic existing validation (#32465)
add 80960d19b61 Remove unused code (#32414)
No new revisions were added by this update.
Summary of changes:
.../beam_Inference_Python_Benchmarks_Dataflow.yml | 12 +-
CHANGES.md | 4 +
runners/prism/java/build.gradle | 5 -
.../beam/runners/prism/PrismArtifactResolver.java | 110 -----------
.../beam/runners/prism/PrismArtifactStager.java | 173 -----------------
.../apache/beam/runners/prism/PrismJobManager.java | 160 ----------------
.../apache/beam/runners/prism/StateListener.java | 27 ---
.../apache/beam/runners/prism/StateWatcher.java | 146 --------------
.../apache/beam/runners/prism/WorkerService.java | 116 -----------
.../runners/prism/PrismArtifactResolverTest.java | 45 -----
.../runners/prism/PrismArtifactStagerTest.java | 143 --------------
.../beam/runners/prism/PrismJobManagerTest.java | 211 ---------------------
.../beam/runners/prism/StateWatcherTest.java | 136 -------------
.../beam/runners/prism/WorkerServiceTest.java | 85 ---------
.../beam/sdk/util/RowStringInterpolator.java | 165 ++++++++++++++++
.../beam/sdk/util/RowStringInterpolatorTest.java | 191 +++++++++++++++++++
.../beam/sdk/io/gcp/pubsub/PubsubClient.java | 3 +
.../beam/sdk/io/gcp/pubsub/PubsubGrpcClient.java | 16 ++
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 94 ++++++++-
.../beam/sdk/io/gcp/pubsub/PubsubJsonClient.java | 14 ++
.../beam/sdk/io/gcp/pubsub/PubsubTestClient.java | 6 +
.../sdk/io/gcp/pubsub/PubsubGrpcClientTest.java | 40 ++++
.../beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 170 +++++++++++++++++
.../sdk/io/gcp/pubsub/PubsubJsonClientTest.java | 24 +++
.../apache/beam/sdk/io/solace/it/SolaceIOIT.java | 1 +
.../tensorrt_runinference/tensor_rt.dockerfile | 6 +-
26 files changed, 736 insertions(+), 1367 deletions(-)
delete mode 100644
runners/prism/java/src/main/java/org/apache/beam/runners/prism/PrismArtifactResolver.java
delete mode 100644
runners/prism/java/src/main/java/org/apache/beam/runners/prism/PrismArtifactStager.java
delete mode 100644
runners/prism/java/src/main/java/org/apache/beam/runners/prism/PrismJobManager.java
delete mode 100644
runners/prism/java/src/main/java/org/apache/beam/runners/prism/StateListener.java
delete mode 100644
runners/prism/java/src/main/java/org/apache/beam/runners/prism/StateWatcher.java
delete mode 100644
runners/prism/java/src/main/java/org/apache/beam/runners/prism/WorkerService.java
delete mode 100644
runners/prism/java/src/test/java/org/apache/beam/runners/prism/PrismArtifactResolverTest.java
delete mode 100644
runners/prism/java/src/test/java/org/apache/beam/runners/prism/PrismArtifactStagerTest.java
delete mode 100644
runners/prism/java/src/test/java/org/apache/beam/runners/prism/PrismJobManagerTest.java
delete mode 100644
runners/prism/java/src/test/java/org/apache/beam/runners/prism/StateWatcherTest.java
delete mode 100644
runners/prism/java/src/test/java/org/apache/beam/runners/prism/WorkerServiceTest.java
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/util/RowStringInterpolator.java
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/util/RowStringInterpolatorTest.java
