Summer Sale Special - Limited Time 70% Discount Offer - Ends in 0d 00h 00m 00s - Coupon code: sntaclus

A data engineer is onboarding a new Bronze ingestion pipeline in Databricks with Unity Catalog. The team wants Databricks to handle storage layout, apply platform optimizations over time, and simplify lifecycle management so that when a table is dropped, its underlying data is also cleaned up according to Databricks-managed retention policies.

Which table type should the data engineer create for these ingestion tables?

A.

Managed tables so that Unity Catalog manages both metadata and underlying data lifecycle

B.

External tables with a LOCATION pointing to an external volume for full control of file layout

C.

Foreign tables federated from an external catalog to delegate optimization to the source system

D.

Temporary views over files to avoid table-level governance and lifecycle coupling

Which single Databricks CLI command deploys local bundle assets to the target workspace specified in the bundle configuration file?

A.

databricks bundle validate

B.

databricks bundle plan & & databricks bundle run

C.

databricks bundle deploy

D.

databricks bundle init & & databricks bundle deployment

A data engineer has a PySpark DataFrame named events_df with the following schema:

event_id STRING,

device STRUCT <</p>

id: STRING,

model: STRING,

location: STRUCT <</p>

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.

events_df.withColumn( " device_id " , events_df[ " device.id " ]).withColumn( " device_model " , events_df[ " device.model " ]).withColumn( " location " , events_df[ " device.location " ])

B.

events_df.select( " event_id " , " event_ts " , " device.* " )

C.

events_df.select( " event_id " , " event_ts " , " device.id " , " device.model " , " device.location.latitude " , " device.location.longitude " )

D.

events_df.select( " event_id " , " device[id] " , " device[model] " , " device.location[latitude] " , " device.location[longitude] " , " event_ts " )

A data engineer is using the OPTIMIZE command on a Delta table. What happens when OPTIMIZE is run twice on the same table with the same data?

A.

It further reduces file sizes by re-clustering the data

B.

Triggers a full liquid clustering process

C.

Changes the number of tuples per file significantly

D.

It has no effect because it is idempotent.

A data engineering team is using Kafka to capture event data and then ingest it into Databricks. The team wants to be able to see these historical events. Medallion architecture is already in place. The team wants to be mindful of costs.

Where should this historical event data be stored?

A.

Gold

B.

Silver

C.

Bronze

D.

Raw layer

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?

A.

org.apache.spark.sql.jdbc

B.

autoloader

C.

DELTA

D.

sqlite

E.

org.apache.spark.sql.sqlite

Which of the following commands can be used to write data into a Delta table while avoiding the writing of duplicate records?

A.

DROP

B.

IGNORE

C.

MERGE

D.

APPEND

E.

INSERT

Which SQL keyword can be used to convert a table from a long format to a wide format?

A.

TRANSFORM

B.

PIVOT

C.

SUM

D.

CONVERT

A data engineer needs to ingest JSON change data from Salesforce into Unity Catalog-governed Delta tables using a low-code, fully managed experience.

Which Databricks capability should the data engineer use?

A.

A Lakeflow Connect managed Salesforce connector that writes to Unity Catalog Delta tables.

B.

The Salesforce REST API in a PySpark notebook to query changed records and write them to Delta tables.

C.

Auto Loader with a file-arrival trigger monitoring DBFS.

D.

Auto Loader reading JSON files from an Amazon S3 bucket populated by a separate Salesforce export process.

Which of the following describes a scenario in which a data team will want to utilize cluster pools?

A.

An automated report needs to be refreshed as quickly as possible.

B.

An automated report needs to be made reproducible.

C.

An automated report needs to be tested to identify errors.

D.

An automated report needs to be version-controlled across multiple collaborators.

E.

An automated report needs to be runnable by all stakeholders.