This is a dedicated watch page for a single video.
A data engineer has configured a Structured Streaming job to read from a table, manipulate the data, and then perform a streaming write into a new table. The cade block used by the data engineer is below: ( spark . table .( "sales" ) . withColumn ( "avg_price" , col ( "sales" )/ col ( "units" )) . withStream . option ( "checkpointLocation" , checkpointPath ) . outputMode ( "complete" ) . ________ . table ( "new_sales" ) ) If the data engineer only wants the query to execute a micro-batch to process data every 5 seconds, which of the following lines of code should the data engineer use to fill in the blank?