Big Halloween Sale Limited Time 70% Discount Offer - Ends in 0d 00h 00m 00s - Coupon code: simple70

Databricks Certified Data Engineer Professional Exam Databricks-Certified-Professional-Data-Engineer Question # 1 Topic 1 Discussion

Databricks Certified Data Engineer Professional Exam Databricks-Certified-Professional-Data-Engineer Question # 1 Topic 1 Discussion

Databricks-Certified-Professional-Data-Engineer Exam Topic 1 Question 1 Discussion:
Question #: 1
Topic #: 1

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:

Databricks-Certified-Professional-Data-Engineer Question 1

Choose the response that correctly fills in the blank within the code block to complete this task.


A.

withWatermark("event_time", "10 minutes")


B.

awaitArrival("event_time", "10 minutes")


C.

await("event_time + ‘10 minutes'")


D.

slidingWindow("event_time", "10 minutes")


E.

delayWrite("event_time", "10 minutes")


Get Premium Databricks-Certified-Professional-Data-Engineer Questions

Contribute your Thoughts:


Chosen Answer:
This is a voting comment (?). It is better to Upvote an existing comment if you don't have anything to add.