Databricks Certified Professional Data Engineer - Databricks-Certified-Professional-Data-Engineer 시험문제 [2026]

문제1
A data engineer has a Delta table orders with deletion vectors enabled. The engineer executes the following command:
DELETE FROM orders WHERE status = ' cancelled ' ;
What should be the behavior of deletion vectors when the command is executed?

A. Rows are marked as deleted both in metadata and in files.

B. Delta automatically removes all cancelled orders permanently.

C. Rows are marked as deleted in metadata, not in files.

D. Files are physically rewritten without the deleted rows.

정답: C

설명: (KoreaDumps 회원만 볼 수 있음)

문제2
A junior data engineer has manually configured a series of jobs using the Databricks Jobs UI. Upon reviewing their work, the engineer realizes that they are listed as the " Owner " for each job. They attempt to transfer " Owner " privileges to the " DevOps " group, but cannot successfully accomplish this task.
Which statement explains what is preventing this privilege transfer?

A. Only workspace administrators can grant " Owner " privileges to a group.

B. Databricks jobs must have exactly one owner; " Owner " privileges cannot be assigned to a group.

C. A user can only transfer job ownership to a group if they are also a member of that group.

D. Other than the default " admins " group, only individual users can be granted privileges on jobs.

E. The creator of a Databricks job will always have " Owner " privileges; this configuration cannot be changed.

정답: B

설명: (KoreaDumps 회원만 볼 수 있음)

문제3
An upstream system is emitting change data capture (CDC) logs that are being written to a cloud object storage directory. Each record in the log indicates the change type (insert, update, or delete) and the values for each field after the change. The source table has a primary key identified by the field pk_id .
For auditing purposes, the data governance team wishes to maintain a full record of all values that have ever been valid in the source system. For analytical purposes, only the most recent value for each record needs to be recorded. The Databricks job to ingest these records occurs once per hour, but each individual record may have changed multiple times over the course of an hour.
Which solution meets these requirements?

A. Create a separate history table for each pk_id resolve the current state of the table by running a union all filtering the history tables for the most recent state.

B. Iterate through an ordered set of changes to the table, applying each in turn; rely on Delta Lake ' s versioning ability to create an audit log.

C. Ingest all log information into a bronze table; use merge into to insert, update, or delete the most recent entry for each pk_id into a silver table to recreate the current table state.

D. Use Delta Lake ' s change data feed to automatically process CDC data from an external system, propagating all changes to all dependent tables in the Lakehouse.

E. Use merge into to insert, update, or delete the most recent entry for each pk_id into a bronze table, then propagate all changes throughout the system.

정답: C

설명: (KoreaDumps 회원만 볼 수 있음)

문제4
A junior data engineer on your team has implemented the following code block.

The view new_events contains a batch of records with the same schema as the events Delta table. The event_id field serves as a unique key for this table.
When this query is executed, what will happen with new records that have the same event_id as an existing record?

A. They are merged.

B. They are deleted.

C. They are ignored.

D. They are inserted.

E. They are updated.

정답: C

설명: (KoreaDumps 회원만 볼 수 있음)

문제5
A data engineer is configuring a Lakeflow Declarative Pipeline to process CDC (Change Data Capture) data from a source. The source events sometimes arrive out of order, and multiple updates may occur with the same update_timestamp but with different update_sequence_id .
What should the data engineer do to ensure events are sequenced correctly?

A. O Set track_history_column_list to [event_timestamp, event_id] in AUTO CDC APIs.

B. O Use a window function to sort update_sequence_id within the same partition, i.e., update_timestamp in the LDP pipeline.

C. O Use dropDuplicates() to remove out-of-order and duplicate records in LDP.

D. O Use SEQUENCE BY STRUCT(event_timestamp, update_sequence_id) in AUTO CDC APIs.

정답: D

설명: (KoreaDumps 회원만 볼 수 있음)

문제6
The following table consists of items found in user carts within an e-commerce website.

The following MERGE statement is used to update this table using an updates view, with schema evaluation enabled on this table.

How would the following update be handled?

A. The update is moved to separate ' ' restored ' ' column because it is missing a column expected in the target schema.

B. The update throws an error because changes to existing columns in the target schema are not supported.

C. The new restored field is added to the target schema, and dynamically read as NULL for existing unmatched records.

D. The new nested field is added to the target schema, and files underlying existing records are updated to include NULL values for the new field.

정답: D

설명: (KoreaDumps 회원만 볼 수 있음)

문제7
What is the first of a Databricks Python notebook when viewed in a text editor?

A. //Databricks notebook source

B. %python

C. % Databricks notebook source

D. -- Databricks notebook source

정답: C

설명: (KoreaDumps 회원만 볼 수 있음)

문제8
A facilities-monitoring team is building a near-real-time PowerBI dashboard off the Delta table device_readings:
Columns:
* device_id (STRING, unique sensor ID)
* event_ts (TIMESTAMP, ingestion timestamp UTC)
* temperature_c (DOUBLE, temperature in °C)
Requirement:
* For each sensor, generate one row per non-overlapping 5-minute interval , offset by 2 minutes (e.g.,
00:02-00:07, 00:07-00:12, ...).
* Each row must include interval start, interval end, and average temperature in that slice.
* Downstream BI tools (e.g., Power BI) must use the interval timestamps to plot time-series bars.
Options:

A. WITH buckets AS (
SELECT device_id,
window(event_ts, ' 5 minutes ' , ' 2 minutes ' , ' 5 minutes ' ) AS win, temperature_c FROM device_readings ) SELECT device_id, win.start AS bucket_start, win.end AS bucket_end, AVG(temperature_c) AS avg_temp_5m FROM buckets GROUP BY device_id, win ORDER BY device_id, bucket_start;

B. SELECT device_id,
date_trunc( ' minute ' , event_ts - INTERVAL 2 MINUTES) + INTERVAL 2 MINUTES AS bucket_start, date_trunc( ' minute ' , event_ts - INTERVAL 2 MINUTES) + INTERVAL 7 MINUTES AS bucket_end, AVG(temperature_c) AS avg_temp_5m FROM device_readings GROUP BY device_id, date_trunc( ' minute ' , event_ts - INTERVAL 2 MINUTES) ORDER BY device_id, bucket_start;

C. SELECT device_id,
window.start AS bucket_start,
window.end AS bucket_end,
AVG(temperature_c) AS avg_temp_5m
FROM device_readings
GROUP BY device_id, window(event_ts, ' 5 minutes ' , ' 5 minutes ' , ' 2 minutes ' ) ORDER BY device_id, bucket_start;

D. SELECT device_id,
event_ts,
AVG(temperature_c) OVER (
PARTITION BY device_id
ORDER BY event_ts
RANGE BETWEEN INTERVAL 5 MINUTES PRECEDING AND CURRENT ROW
) AS avg_temp_5m
FROM device_readings
WINDOW w AS (window(event_ts, ' 5 minutes ' , ' 2 minutes ' ));

정답: A

설명: (KoreaDumps 회원만 볼 수 있음)

문제9
To identify the top users consuming compute resources, a data engineering team needs to monitor usage within their Databricks workspace for better resource utilization and cost control. The team decided to use Databricks system tables, available under the system catalog in Unity Catalog, to gain detailed visibility into workspace activity. Which SQL query should the team run from the system catalog to achieve this?

A. SELECT
sku_name,
usage_metadata.run_name AS user_email,
SUM(usage_quantity) AS total_dbus
FROM system.billing.usage
GROUP BY user_email, sku_name
ORDER BY total_dbus DESC
LIMIT 10

B. SELECT
sku_name,
identity_metadata.created_by AS user_email,
COUNT(usage_quantity) AS total_dbus
FROM system.billing.usage
GROUP BY user_email, sku_name
ORDER BY total_dbus DESC
LIMIT 10

C. SELECT
identity_metadata.run_as AS user_email,
SUM(usage_quantity) AS total_dbus
FROM system.billing.usage
GROUP BY user_email
ORDER BY total_dbus DESC
LIMIT 10

D. SELECT
sku_name,
identity_metadata.created_by AS user_email,
SUM(usage_quantity * usage_unit) AS total_dbus
FROM system.billing.usage
GROUP BY user_email, sku_name
ORDER BY total_dbus DESC
LIMIT 10

정답: C

설명: (KoreaDumps 회원만 볼 수 있음)

문제10
A table is registered with the following code:

Both users and orders are Delta Lake tables. Which statement describes the results of querying recent_orders ?

A. All logic will execute when the table is defined and store the result of joining tables to the DBFS; this stored data will be returned when the table is queried.

B. The versions of each source table will be stored in the table transaction log; query results will be saved to DBFS with each query.

C. Results will be computed and cached when the table is defined; these cached results will incrementally update as new records are inserted into source tables.

D. All logic will execute at query time and return the result of joining the valid versions of the source tables at the time the query began.

E. All logic will execute at query time and return the result of joining the valid versions of the source tables at the time the query finishes.

정답: A

문제11
The data science team has requested assistance in accelerating queries on free form text from user reviews.
The data is currently stored in Parquet with the below schema:
item_id INT, user_id INT, review_id INT, rating FLOAT, review STRING
The review column contains the full text of the review left by the user. Specifically, the data science team is looking to identify if any of 30 key words exist in this field.
A junior data engineer suggests converting this data to Delta Lake will improve query performance.
Which response to the junior data engineer s suggestion is correct?

A. ZORDER ON review will need to be run to see performance gains.

B. The Delta log creates a term matrix for free text fields to support selective filtering.

C. Delta Lake statistics are not optimized for free text fields with high cardinality.

D. Delta Lake statistics are only collected on the first 4 columns in a table.

E. Text data cannot be stored with Delta Lake.

정답: C

설명: (KoreaDumps 회원만 볼 수 있음)

문제12
To reduce storage and compute costs, the data engineering team has been tasked with curating a series of aggregate tables leveraged by business intelligence dashboards, customer-facing applications, production machine learning models, and ad hoc analytical queries.
The data engineering team has been made aware of new requirements from a customer-facing application, which is the only downstream workload they manage entirely. As a result, an aggregate table used by numerous teams across the organization will need to have a number of fields renamed, and additional fields will also be added.
Which of the solutions addresses the situation while minimally interrupting other teams in the organization without increasing the number of tables that need to be managed?

A. Add a table comment warning all users that the table schema and field names will be changing on a given date; overwrite the table in place to the specifications of the customer-facing application.

B. Send all users notice that the schema for the table will be changing; include in the communication the logic necessary to revert the new table schema to match historic queries.

C. Replace the current table definition with a logical view defined with the query logic currently writing the aggregate table; create a new table to power the customer-facing application.

D. Configure a new table with all the requisite fields and new names and use this as the source for the customer-facing application; create a view that maintains the original data schema and table name by aliasing select fields from the new table.

E. Create a new table with the required schema and new fields and use Delta Lake ' s deep clone functionality to sync up changes committed to one table to the corresponding table.

정답: D

설명: (KoreaDumps 회원만 볼 수 있음)

문제13
A workspace admin has created a new catalog called finance_data and wants to delegate permission management to a finance team lead without giving them full admin rights.
Which privilege should be granted to the finance team lead?

A. GRANT OPTION privilege on the finance_data catalog.

B. Make the finance team lead a metastore admin.

C. MANAGE privilege on the finance_data catalog.

D. ALL PRIVILEGES on the finance_data catalog.

정답: C

설명: (KoreaDumps 회원만 볼 수 있음)

최신Databricks Certified Professional Data Engineer - Databricks-Certified-Professional-Data-Engineer무료샘플문제

KoreaDumps의 제품으로 GO GO GO !

자격증의 중요성:

KoreaDumps 제품의 가치:

무료샘플 받아보기:

완벽한 서비스 제공: