Certified Machine Learning Professional Exam

Exam Certified Machine Learning Professional All QuestionsBrowse all questions from this exam

Question 45

A machine learning engineer is using the following code block as part of a batch deployment pipeline:

Which of the following changes needs to be made so this code block will work when the inference table is a stream source?

Replace "inference" with the path to the location of the Delta table

Replace schema(schema) with option("maxFilesPerTrigger", 1)

Replace spark.read with spark.readStream

Replace format("delta") with format("stream")

Replace predict with a stream-friendly prediction function

Correct Answer: C

To work with a stream source in Apache Spark, you need to use the 'spark.readStream' method instead of 'spark.read'. This ensures that the DataFrame is being read as a streaming DataFrame, which is necessary for handling streaming data sources such as a Delta table that is continuously receiving new data.

Discussion

trendy01Option: C

C. Replace spark.read with spark.readStream

hugodscarvalhoOption: C

This change ensures that the DataFrame is being read as a streaming DataFrame from the stream source.

mozucaOption: C

Agree with trendy01