This approach uses a Spark Structured Streaming read from the continuously updated Delta table and applies an MLflow-registered Spark UDF for inference. The model execution is distributed across the three executors, enabling parallel, low-latency scoring as new data arrives. Writing the results with writeStream efficiently updates the forecast_results Delta table incrementally, maximizing cluster utilization and aligning with best practices for continuous, scalable batch- stream inference in Databricks.