This is an automated email from the ASF dual-hosted git repository. damccorm pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
from 01aa470cf72 [Spark Runner] Add new experiment that provides concurrent bounded output for SDFs (resolves #23852) (#24837) add 10805a2d402 Add sideinputs to the RunInference Transform (#25200) No new revisions were added by this update. Summary of changes: CHANGES.md | 31 ++++ .../inference/run_inference_side_inputs.py | 165 +++++++++++++++++++ .../transforms/elementwise/runinference_test.py | 45 +++--- sdks/python/apache_beam/ml/inference/base.py | 161 +++++++++++++++---- sdks/python/apache_beam/ml/inference/base_test.py | 177 ++++++++++++++++++++- .../apache_beam/ml/inference/pytorch_inference.py | 75 ++++----- .../ml/inference/pytorch_inference_test.py | 5 +- .../apache_beam/ml/inference/sklearn_inference.py | 37 ++--- .../apache_beam/ml/inference/tensorrt_inference.py | 13 +- sdks/python/apache_beam/ml/inference/utils.py | 48 ++++++ 10 files changed, 637 insertions(+), 120 deletions(-) create mode 100644 sdks/python/apache_beam/examples/inference/run_inference_side_inputs.py create mode 100644 sdks/python/apache_beam/ml/inference/utils.py