
Ultimate access to all questions.
Consider the following Structured Streaming query in Databricks:
spark.table("orders")
.withColumn("total_after_tax", col("total") + col("tax"))
.writeStream
.option("checkpointLocation", checkpointPath)
.outputMode("append")
._____________
.table("new_orders")
spark.table("orders")
.withColumn("total_after_tax", col("total") + col("tax"))
.writeStream
.option("checkpointLocation", checkpointPath)
.outputMode("append")
._____________
.table("new_orders")
Which option correctly fills in the blank to execute a micro-batch processing of data every 2 minutes?_
A
trigger(once="2 minutes")
B
trigger(processingTime="2 minutes")
C
processingTime("2 minutes")
D
trigger("2 minutes")
E
trigger()