A data engineer is using the following code block as part of a batch ingestion pipeline to read from a composable table:

Which of the following changes needs to be made so this code block will work when the transactions table is a stream source?

• A.Replace predict with a stream-friendly prediction function
• B.Replace schema(schema) with option ("maxFilesPerTrigger", 1)
• C.Replace "transactions" with the path to the location of the Delta table
• D.Replace format("delta") with format("stream")
• E.Replace spark.read with spark.readStream

Comment: *

Name: *

Email: *

Verification: *

A single Job runs two notebooks as two separate tasks. A data engineer has noticed that one of the notebooks is running slowly in the Job's current run. The data engineer asks a tech lead for help in identifying why this might be the case.
Which of the following approaches can the tech lead use to identify why the notebook is running slowly as part of the Job?

• A.They can navigate to the Runs tab in the Jobs UI and click on the active run to review the processing notebook.
• B.They can navigate to the Runs tab in the Jobs UI to immediately review the processing notebook.
• C.There is no way to determine why a Job task is running slowly.
• D.They can navigate to the Tasks tab in the Jobs UI and click on the active run to review the processing notebook.
• E.They can navigate to the Tasks tab in the Jobs UI to immediately review the processing notebook.

Comment: *

Name: *

Email: *

Verification: *

Which of the following describes a benefit of creating an external table from Parquet rather than CSV when using a CREATE TABLE AS SELECT statement?

• A.Parquet files can be partitioned
• B.CREATE TABLE AS SELECT statements cannot be used on files
• C.Parquet files have a well-defined schema
• D.Parquet files have the ability to be optimized
• E.Parquet files will become Delta tables

Comment: *

Name: *

Email: *

Verification: *

A data engineering team has noticed that their Databricks SQL queries are running too slowly when they are submitted to a non-running SQL endpoint. The data engineering team wants this issue to be resolved.
Which of the following approaches can the team use to reduce the time it takes to return results in this scenario?

• A.They can turn on the Serverless feature for the SQL endpoint and change the Spot Instance Policy to
  "Reliability Optimized."
• B.They can turn on the Auto Stop feature for the SQL endpoint.
• C.They can increase the cluster size of the SQL endpoint.
• D.They can turn on the Serverless feature for the SQL endpoint.
• E.They can increase the maximum bound of the SQL endpoint's scaling range

Comment: *

Name: *

Email: *

Verification: *

A data analyst has developed a query that runs against Delta table. They want help from the data engineering team to implement a series of tests to ensure the data returned by the query is clean. However, the data engineering team uses Python for its tests rather than SQL.
Which of the following operations could the data engineering team use to run the query and operate with the results in PySpark?

• A.SELECT * FROM sales
• B.spark.delta.table
• C.spark.sql
• D.There is no way to share data between PySpark and SQL.
• E.spark.table

Comment: *

Name: *

Email: *

Verification: *