Ultimate access to all questions.
Upgrade Now 🚀
Sign in to unlock AI tutor
Identify the Structured Streaming query that performs a hop from a bronze table to a Silver table by enriching the data without aggregation.
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").agg(sum("sales"),sum("units")).writeStream.option("checkpointLocation",checkpointPath).outputMode("complete").table("aggregatedSales"))
