Ultimate access to all questions.
Upgrade Now 🚀
Sign in to unlock AI tutor
Which Structured Streaming query correctly transitions data from a Silver to a Gold table in Databricks?
A
(spark.read.load(rawSalesLocation) .writeStream .option(“checkpointLocation“, checkpointPath) .outputMode(“append“) .table(“uncleanedSales“) )
B
(spark.table(“sales“) .groupBy(“store“) .agg(sum(“sales“)) .writeStream .option(“checkpointLocation“, checkpointPath) .outputMode(“complete“) .table(“aggregatedSales“) )
C
(spark.table(“sales“) .withColumn(“avgPrice“, col(“sales“) / col(“units“)) .writeStream .option(“checkpointLocation“, checkpointPath) .outputMode(“append“) .table(“cleanedSales“) )
D
(spark.readStream.load(rawSalesLocation) .writeStream .option(“checkpointLocation“, checkpointPath) .outputMode(“append“) .table(“uncleanedSales“) )
E
(spark.table(“sales“) .writeStream .option(“checkpointLocation“, checkpointPath) .outputMode(“complete“) .table(“sales“) )
