Given the following Structured Streaming query:

spark.table("orders")
    .withColumn("total_after_tax", col("total") + col("tax"))
    .writeStream
    .option("checkpointLocation", checkpointPath)
    .outputMode("append")
    .______________
    .table("new_orders")

Fill in the blank to make the query execute a micro-batch to process data every 2 minutes.