Question

A data engineer needs to build a continuously-running Structured Streaming job that reads from an existing Delta table used as the source and writes aggregated results to another Delta table. Which read configuration correctly establishes the streaming source from the Delta table?

Accepted Answer

spark.readStream.format("delta").table("source_events")

Answer

spark.read.format("delta").table("source_events")

Answer

spark.readStream.format("cloudFiles").option("cloudFiles.format", "delta").load("source_events")

Answer

spark.readStream.format("kafka").table("source_events")