🔍

Databricks Certified Data Engineer Professional DATA-ENGINEER-PROFESSIONAL — Question 61

Topic 1 · Question 61 of 110

Topic 1 · Question 61

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. Events are recorded once per minute per device. Streaming DataFrame df has the following schema: "device_id INT, event_time TIMESTAMP, temp FLOAT, humidity FLOAT" Code block: Which line of code correctly fills in the blank within the code block to complete this task?

Exhibit 1 for question 61

View community discussion →