Câu 59: Databricks Certified Data Engineer Professional

A junior data engineer has been asked to develop a streaming data pipeline with a grouped aggregation using DataFrame df. The pipeline needs to calculate the average humidity and average temperature for each non-overlapping five-minute interval. Incremental state information should be maintained for 10 minutes for late-arriving data. Streaming DataFrame df has the following schema:"device_id INT, event_time TIMESTAMP, temp FLOAT, humidity FLOAT"Code block: Choose the response that correctly fills in the blank within the code block to complete this task.

1. A. withWatermark("event_time", "10 minutes") — đáp án hiện tại
2. B. awaitArrival("event_time", "10 minutes")
3. C. await("event_time + ‘10 minutes'")
4. D. slidingWindow("event_time", "10 minutes")
5. E. delayWrite("event_time", "10 minutes")