Ingest Data into Unity Catalog DP-750 Practice Questions (Page 2)

Questions 6–10

1. 6expert · hard

   A data engineer is responsible for ingesting daily CSV exports into a Unity Catalog table. The files are delivered to an external location, and the engineer needs to ensure that only new files are processed each day. The table already exists and contains historical data. The engineer wants to use a SQL statement that is idempotent and does not require manual tracking of processed files. Which SQL statement should they use?

   • AMERGE INTO sales.daily USING csv.`/mnt/external/daily` ON ...
   • BCREATE OR REPLACE TABLE sales.daily USING DELTA AS SELECT * FROM csv.`/mnt/external/daily`
   • CCOPY INTO sales.daily FROM '/mnt/external/daily' FILEFORMAT = CSV
   • DINSERT INTO sales.daily SELECT * FROM csv.`/mnt/external/daily`
   Reveal Solution Discussion Select an answer first
2. 7expert · hard

   A data engineer needs to ingest a CDC feed from a database into a Unity Catalog Delta table. The feed is delivered as a stream of change records in a Kafka topic. The engineer wants to use Spark Structured Streaming in a notebook and ensure that the target table is eventually consistent with the source, even if some events arrive out of order. The engineer also needs to handle late-arriving events. Which approach should the engineer use?

   • AUse append mode to write the CDC records directly to the Delta table.
   • BUse Spark Structured Streaming with Kafka source and foreachBatch to apply MERGE with a timestamp-based conflict resolution.
   • CUse Auto Loader to ingest Kafka messages as files and then process with batch Spark.
   • DUse Lakeflow Connect Streaming Ingestion to create a streaming pipeline from Kafka.
   Reveal Solution Discussion Select an answer first
4. 8foundation · easy

   In a CDC feed, what column typically indicates whether a record is an insert, update, or delete?

   • ATimestamp column
   • BSource system name
   • COperation type column (e.g., 'I', 'U', 'D')
   • DPrimary key column
   Reveal Solution Discussion Select an answer first
5. 9foundation · easy

   Which API is used to process streaming data in Databricks notebooks and write it to Unity Catalog tables?

   • ASpark Structured Streaming
   • BSpark Streaming (DStreams)
   • CSpark SQL streaming
   • DDatabricks Delta Live Tables
   Reveal Solution Discussion Select an answer first
6. 10application · medium

   A data engineer needs to ingest data from a SaaS application (e.g., Salesforce) into a Unity Catalog table on a scheduled basis. The engineer wants to use a managed service that handles the connection and incremental loading without writing code. Which approach should the engineer use?

   • AUse a notebook with Spark Structured Streaming to read from the SaaS API.
   • BUse COPY INTO to load files exported from the SaaS application.
   • CUse Auto Loader to ingest files from a staging directory.
   • DUse Lakeflow Connect Batch Ingestion to create a batch pipeline from the SaaS source to Unity Catalog.
   Reveal Solution Discussion Select an answer first