Ultimate access to all questions.
Upgrade Now 🚀
Sign in to unlock AI tutor
Question 31
Which of the following Structured Streaming queries is performing a hop from a Bronze table to a Silver table?
A
(spark.table("sales") .groupBy("store") .agg(sum("sales")) .writeStream .option("checkpointLocation", checkpointPath) .outputMode("complete") .table("aggregatedSales"))
B
(spark.table("sales") .agg(sum("sales"), sum("units")) .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.read.load(rawSalesLocation) .writeStream
