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 c0a58953470 Fix zero key length panic in Prism (#36983)
add efb37195348 Fix python postcommit
add 82dea870b92 Merge pull request #36977 from apache/users/damccorm/hdfsIT
add b59f3d93ef3 Bump github.com/spf13/cobra from 1.10.1 to 1.10.2 in /sdks
(#36987)
add ece2beb0659 Java Native Remote Inference (#36623)
add 1831cbaae95 Fix data race in test. (#36992)
add 9bcae0d5e03 Use HashMap.computeIfAbsent instead of get/put (#36990)
add fc31402d928 Attempt to fix flaky test by not requiring advance to
succeed immediately (#36976)
add 7b4a4c9e6f1 Update Python Dependencies (#36994)
add 3ce2abdc505 Bump jws from 4.0.0 to 4.0.1 in /sdks/typescript (#36996)
No new revisions were added by this update.
Summary of changes:
.github/trigger_files/beam_PostCommit_Python.json | 2 +-
build.gradle.kts | 2 +
.../beam/runners/dataflow/worker/WindmillSink.java | 14 +-
sdks/go.mod | 2 +-
sdks/go.sum | 5 +-
.../fn/splittabledofn/RestrictionTrackersTest.java | 2 +-
sdks/java/extensions/ml/build.gradle | 1 +
.../java/org/apache/beam/sdk/io/jms/JmsIOTest.java | 28 +-
.../jackson => ml/inference/openai}/build.gradle | 26 +-
.../ml/inference/openai/OpenAIModelHandler.java | 166 ++++++
.../sdk/ml/inference/openai/OpenAIModelInput.java | 63 +++
.../ml/inference/openai/OpenAIModelParameters.java | 114 ++++
.../ml/inference/openai/OpenAIModelResponse.java | 61 +++
.../ml/inference/openai/OpenAIModelHandlerIT.java | 402 ++++++++++++++
.../inference/openai/OpenAIModelHandlerTest.java | 450 ++++++++++++++++
.../inference/remote}/build.gradle | 26 +-
.../beam/sdk/ml/inference/remote/BaseInput.java} | 16 +-
.../sdk/ml/inference/remote/BaseModelHandler.java | 69 +++
.../ml/inference/remote/BaseModelParameters.java} | 41 +-
.../sdk/ml/inference/remote/BaseResponse.java} | 16 +-
.../sdk/ml/inference/remote/PredictionResult.java | 53 ++
.../sdk/ml/inference/remote/RemoteInference.java | 170 ++++++
.../beam/sdk/ml/inference/remote/RetryHandler.java | 103 ++++
.../ml/inference/remote/RemoteInferenceTest.java | 598 +++++++++++++++++++++
.../hdfs_integration_test/hdfs_integration_test.sh | 2 +-
.../container/ml/py310/base_image_requirements.txt | 80 ++-
.../container/ml/py310/gpu_image_requirements.txt | 108 ++--
.../container/ml/py311/base_image_requirements.txt | 80 ++-
.../container/ml/py311/gpu_image_requirements.txt | 108 ++--
.../container/ml/py312/base_image_requirements.txt | 80 ++-
.../container/ml/py312/gpu_image_requirements.txt | 108 ++--
.../container/ml/py313/base_image_requirements.txt | 80 ++-
.../container/py310/base_image_requirements.txt | 66 ++-
.../container/py311/base_image_requirements.txt | 64 ++-
.../container/py312/base_image_requirements.txt | 64 ++-
.../container/py313/base_image_requirements.txt | 64 ++-
sdks/python/tox.ini | 2 +-
sdks/typescript/package-lock.json | 36 +-
settings.gradle.kts | 3 +
39 files changed, 2811 insertions(+), 564 deletions(-)
copy sdks/java/{extensions/jackson => ml/inference/openai}/build.gradle (65%)
create mode 100644
sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai/OpenAIModelHandler.java
create mode 100644
sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai/OpenAIModelInput.java
create mode 100644
sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai/OpenAIModelParameters.java
create mode 100644
sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai/OpenAIModelResponse.java
create mode 100644
sdks/java/ml/inference/openai/src/test/java/org/apache/beam/sdk/ml/inference/openai/OpenAIModelHandlerIT.java
create mode 100644
sdks/java/ml/inference/openai/src/test/java/org/apache/beam/sdk/ml/inference/openai/OpenAIModelHandlerTest.java
copy sdks/java/{extensions/timeseries => ml/inference/remote}/build.gradle
(70%)
copy sdks/{python/test-suites/tox/py311/build.gradle =>
java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/BaseInput.java}
(74%)
create mode 100644
sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/BaseModelHandler.java
copy sdks/{python/test-suites/tox/pycommon/build.gradle =>
java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/BaseModelParameters.java}
(50%)
copy
sdks/java/{io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/package-info.java
=>
ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/BaseResponse.java}
(66%)
create mode 100644
sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/PredictionResult.java
create mode 100644
sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/RemoteInference.java
create mode 100644
sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/RetryHandler.java
create mode 100644
sdks/java/ml/inference/remote/src/test/java/org/apache/beam/sdk/ml/inference/remote/RemoteInferenceTest.java
