A data engineer is using the following code block as part of a batch ingestion...

Databricks Databricks-Certified-Data-Engineer-Associate Question Answer

A data engineer is using the following code block as part of a batch ingestion pipeline to read from a composable table:

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

Replace predict with a stream-friendly prediction function

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

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

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

Replace spark.read with spark.readStream

Databricks-Certified-Data-Engineer-Associate PDF/Engine

Get 65% Discount on All Products, Use Coupon: "ac4s65"