A data engineer has configured a Structured Streaming job to read from a table, manipulate the data, and then perform a streaming write into a new table.
The code block used by the data engineer is below:

If the data engineer only wants the query to process all of the available data in as many batches as required, which of the following lines of code should the data engineer use to fill in the blank?

• A.processingTime(1)
• B.trigger(availableNow=True)
• C.trigger(parallelBatch=True)
• D.trigger(processingTime="once")
• E.trigger(continuous="once")

Comment: *

Name: *

Email: *

Verification: *

A data engineer is attempting to drop a Spark SQL table my_table. The data engineer wants to delete all table metadata and data.
They run the following command:
DROP TABLE IF EXISTS my_table
While the object no longer appears when they run SHOW TABLES, the data files still exist.
Which of the following describes why the data files still exist and the metadata files were deleted?

• A.The table's data was larger than 10 GB
• B.The table was external
• C.The table's data was smaller than 10 GB
• D.The table did not have a location
• E.The table was managed

Comment: *

Name: *

Email: *

Verification: *

A data engineer has joined an existing project and they see the following query in the project repository:
CREATE STREAMING LIVE TABLE loyal_customers AS
SELECT customer_id -
FROM STREAM(LIVE.customers)
WHERE loyalty_level = 'high';
Which of the following describes why the STREAM function is included in the query?

• A.The STREAM function is not needed and will cause an error.
• B.The table being created is a live table.
• C.The customers table is a streaming live table.
• D.The customers table is a reference to a Structured Streaming query on a PySpark DataFrame.
• E.The data in the customers table has been updated since its last run.

Comment: *

Name: *

Email: *

Verification: *

Which of the following tools is used by Auto Loader process data incrementally?

• A.Databricks SQL
• B.Data Explorer
• C.Unity Catalog
• D.Checkpointing
• E.Spark Structured Streaming

Comment: *

Name: *

Email: *

Verification: *

Which of the following approaches should be used to send the Databricks Job owner an email in the case that the Job fails?

• A.Manually programming in an alert system in each cell of the Notebook
• B.Setting up an Alert in the Job page
• C.Setting up an Alert in the Notebook
• D.There is no way to notify the Job owner in the case of Job failure
• E.MLflow Model Registry Webhooks

Comment: *

Name: *

Email: *

Verification: *