In the context of a Structured Streaming job within Databricks, a data engineer has set up a process to read from an existing table, perform necessary data transformations, and write the results into a new table in a streaming fashion. To ensure that the streaming job processes data in micro-batches every 5 seconds, which line of code should the data engineer use to fill in the blank?