Databricks-Certified-Data-Engineer-Professional Exam Question 101

A company stores account transactions in a Delta Lake table. The company needs to apply frequent account-level correlations (e.g., UPDATE statements) but wants to avoid rewriting entire Parquet files for each change to reduce file churn and improve write performance. Which Delta Lake feature should they enable?
  • Databricks-Certified-Data-Engineer-Professional Exam Question 102

    The data governance team has instituted a requirement that the "user" table containing Personal Identifiable Information (PII) must have the appropriate masking on the SSN column. This means that anyone outside of the HRAdminGroup should see masked social security numbers as ***-**-
    ****.
    The team created a masking function:

    What does the data governance team need to do next to achieve this goal?
  • Databricks-Certified-Data-Engineer-Professional Exam Question 103

    A distributed team of data analysts share computing resources on an interactive cluster with autoscaling configured. In order to better manage costs and query throughput, the workspace administrator is hoping to evaluate whether cluster upscaling is caused by many concurrent users or resource-intensive queries.
    In which location can one review the timeline for cluster resizing events?
  • Databricks-Certified-Data-Engineer-Professional Exam Question 104

    The downstream consumers of a Delta Lake table have been complaining about data quality issues impacting performance in their applications. Specifically, they have complained that invalid latitude and longitude values in the activity_details table have been breaking their ability to use other geolocation processes.
    A junior engineer has written the following code to add CHECK constraints to the Delta Lake table:

    A senior engineer has confirmed the above logic is correct and the valid ranges for latitude and longitude are provided, but the code fails when executed.
    Which statement explains the cause of this failure?
  • Databricks-Certified-Data-Engineer-Professional Exam Question 105

    A data engineer is analyzing transactional data in a PySpark DataFrame df containing customer_id, transaction_timestamp (precise to milliseconds), and amount_spent. The objective is to compute a cumulative sum of amount_spent per customer, strictly ordered by transaction_timestamp. The cumulative sum must include all transactions from the earliest timestamp up to and including the current row, respecting temporal ordering within each customer partition. Which PySpark code snippet most accurately constructs the appropriate window specification and applies the aggregation to yield the correct cumulative expenditure per customer?