Question 106 of 307
Single answerA 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.
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.
✓AwithWatermark("event_time", "10 minutes")
BawaitArrival("event_time", "10 minutes")
Cawait("event_time + ‘10 minutes'")
DslidingWindow("event_time", "10 minutes")
EdelayWrite("event_time", "10 minutes")
✓
Correct Answer: A
withWatermark("event_time", "10 minutes")
▥
Explanation
The correct answer is highlighted above. Review the wording carefully, then use the next question to continue building your understanding of Google certification topics.