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 Apache Beam Machine Learning 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.