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

The data engineer team has been tasked with configured connections to an external database that does not have a supported native connector with Databricks. The external database already has data security configured by group membership. These groups map directly to user group already created in Databricks that represent various teams within the company. A new login credential has been created for each group in the external database. The Databricks Utilities Secrets module will be used to make these credentials available to Databricks users. Assuming that all the credentials are configured correctly on the external database and group membership is properly configured on Databricks, which statement describes how teams can be granted the minimum necessary access to using these credentials?
  • Databricks-Certified-Data-Engineer-Professional Exam Question 107

    A data engineer needs to implement column masking for a sensitive column in a Unity Catalog- managed table. The masking logic must dynamically check if users belong to specific groups defined in a separate table (group_access) that maps groups to allowed departments. Which approach should the engineer use to efficiently enforce this requirement?
  • Databricks-Certified-Data-Engineer-Professional Exam Question 108

    A junior developer complains that the code in their notebook isn't producing the correct results in the development environment. A shared screenshot reveals that while they're using a notebook versioned with Databricks Repos, they're using a personal branch that contains old logic. The desired branch named dev-2.3.9 is not available from the branch selection dropdown.
    Which approach will allow this developer to review the current logic for this notebook?
  • Databricks-Certified-Data-Engineer-Professional Exam Question 109

    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:

    Choose the response that correctly fills in the blank within the code block to complete this task.
  • Databricks-Certified-Data-Engineer-Professional Exam Question 110

    Which statement describes the correct use of pyspark.sql.functions.broadcast?