Free Databricks-Certified-Professional-Data-Engineer Mock Exam – Practice Online Confidently

Which of the following describes Cron syntax in Databricks Jobs ?

A data engineer is building a Lakeflow Declarative Pipelines pipeline to process healthcare claims data. A

metadata JSON file defines data quality rules for multiple tables, including:

{

"claims": [

{"name": "valid_patient_id", "constraint": "patient_id IS NOT NULL"},

{"name": "non_negative_amount", "constraint": "claim_amount >= 0"}

]

}

The pipeline must dynamically apply these rules to the claims table without hardcoding the rules.

How should the data engineer achieve this?

A data engineer wants to join a stream of advertisement impressions (when an ad was shown) with another stream of user clicks on advertisements to correlate when impressions led to monetizable clicks.

In the code below, Impressions is a streaming DataFrame with a watermark ("event_time", "10 minutes")

The data engineer notices the query slowing down significantly.

Which solution would improve the performance?

A data engineer has a streaming job that updates a Delta table named ‘user_activities’ by the results of a join between a streaming Delta table ‘activity_logs’ and a static Delta table ‘users’.

They noticed that adding new users into the ‘users’ table does not automatically trigger updates to the ‘user_activities’ table, even when there were activities for those users in the ‘activity_logs’ table.

Which of the following likely explains this issue ?

The data engineering team has a singleplex bronze table called ‘orders_raw’ where new orders data is appended every night. They created a new Silver table called ‘orders_cleaned’ in order to provide a more refined view of the orders data.

The team wants to create a batch processing pipeline to process all new records inserted in the orders_raw table and propagate them to the orders_cleaned table.

Which solution minimizes the compute costs to propagate this batch of data?