Starting with the Apache Beam SDK version 2.40, users have access to a RunInference transform.
This transform allows you to make predictions and inference on data with machine learning (ML) models. The model handler abstracts the user from the configuration needed for specific frameworks, such as Tensorflow, PyTorch, and others. For a full list of supported frameworks, see the About Beam ML page.
These notebooks illustrate ways to use Apache Beam's RunInference transforms, as well as different use cases for ModelHandler
implementations. Beam comes with multiple ModelHandler
implementations.
https://github.com/apache/beam/blob/master/examples/notebooks/beam-ml/run_inference_tensorflow.ipynb
This section contains the following example notebooks.