Question 116

An upstream source writes Parquet data as hourly batches to directories named with the current date. A nightly batch job runs the following code to ingest all data from the previous day as indicated by thedatevariable:

Assume that the fieldscustomer_idandorder_idserve as a composite key to uniquely identify each order.
If the upstream system is known to occasionally produce duplicate entries for a single order hours apart, which statement is correct?
  • Question 117

    A data engineer has ingested data from an external source into a PySpark DataFrame raw_df. They need to
    briefly make this data available in SQL for a data analyst to perform a quality assurance check on the data.
    Which of the following commands should the data engineer run to make this data available in SQL for only
    the remainder of the Spark session?
  • Question 118

    A data engineer has created a new cluster using shared access mode with default configurations. The data engineer needs to allow the development team access to view the driver logs if needed.
    What are the minimal cluster permissions that allow the development team to accomplish this?
  • Question 119

    A data engineer, User A, has promoted a new pipeline to production by using the REST API to programmatically create several jobs. A DevOps engineer, User B, has configured an external orchestration tool to trigger job runs through the REST API. Both users authorized the REST API calls using their personal access tokens.
    Which statement describes the contents of the workspace audit logs concerning these events?
  • Question 120

    Which of the following programming languages can be used to build a Databricks SQL dashboard?