최신Databricks Certified Data Engineer Associate - Databricks-Certified-Data-Engineer-Associate무료샘플문제
A data engineer needs to create a table in Databricks using data from their organization's existing SQLite database.
They run the following command:

Which of the following lines of code fills in the above blank to successfully complete the task?
In order for Structured Streaming to reliably track the exact progress of the processing so that it can handle any kind of failure by restarting and/or reprocessing, which of the following two approaches is used by Spark to record the offset range of the data being processed in each trigger?
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 data engineer has a PySpark DataFrame named events_df with the following schema:
event_id STRING,
device STRUCT<
id: STRING,
model: STRING,
location: STRUCT<
latitude: DOUBLE,
longitude: DOUBLE
>
>,
event_ts TIMESTAMP
The engineer needs to flatten all nested device fields into root-level columns while retaining the event identifier and timestamp.
Which PySpark expression achieves this requirement?
A data engineering team uses Declarative Automation Bundles, formerly known as Databricks Asset Bundles, to deploy the same codebase across development, test, and production environments. The team wants environment-specific behavior to be applied only through bundle configuration, without modifying notebooks, job definitions, or deployment logic during promotion.
Which approach applies environment-specific configuration while meeting this requirement?
A data engineer uploads a CSV file using the Create or modify a table using file upload option in Databricks. To avoid incorrect schema inference, the engineer disables Automatically detect column types before creating a Unity Catalog-managed table.
What is the outcome?
A data engineer needs to migrate the Unity Catalog external Delta table catalog.schema.sales while meeting the following requirements:
Databricks must manage file cleanup after the table is dropped.
The migration must minimize downtime while retaining the same table name, permissions, and history.
Access must be enforced through the registered Unity Catalog table name.
Which action should the engineer take?
A new data engineering team team has been assigned to an ELT project. The new data engineering team will need full privileges on the table sales to fully manage the project.
Which of the following commands can be used to grant full permissions on the database to the new data engineering team?
A data engineer has a Python variable table_name that they would like to use in a SQL query. They want to construct a Python code block that will run the query using table_name.
They have the following incomplete code block:
____(f"SELECT customer_id, spend FROM {table_name}")
Which of the following can be used to fill in the blank to successfully complete the task?
A Delta Live Table pipeline includes two datasets defined using streaming live table. Three datasets are defined against Delta Lake table sources using live table.
The table is configured to run in Production mode using the Continuous Pipeline Mode.
What is the expected outcome after clicking Start to update the pipeline assuming previously unprocessed data exists and all definitions are valid?
A data engineer needs Task C to run only when Task A succeeds and Task B fails.
Which dependency configuration implements this conditional logic?
Which of the following commands will return the number of null values in the member_id column?