Pass Databricks Certified Data Engineer Professional Exam in First Attempt Easily
Real Databricks Certified Data Engineer Professional Exam Questions, Accurate & Verified Answers As Experienced in the Actual Test!

Verified by experts
2 products

You save $34.99

Certified Data Engineer Professional Premium Bundle

  • Premium File 339 Questions & Answers
  • Last Update: Oct 28, 2026
  • Training Course 33 Lectures
$74.99 $109.98

Purchase Individually

  • Premium File

    339 Questions & Answers
    Last Update: Oct 28, 2026

    $76.99
    $69.99
  • Training Course

    33 Lectures

    $43.99
    $39.99

Certified Data Engineer Professional Practice Test 15

Question 140

A data engineer applies an AI text function to raw PII and plans to send results to unrestricted analysts.

Which semi-structured or AI-processing design best fits this case?

  1. Extract and cast the required VARIANT path into a validated numeric column with error handling
  2. Redact or minimize sensitive source fields and validate AI-function data-handling permissions before invocation
  3. Parse the nested array and use an explode operation while retaining the parent event identifier
  4. Store flexible semi-structured payloads in a VARIANT column with intentional extraction of queried paths

Explanation

Correct Answer

B:

Model-based enrichment should process only permitted data and must not bypass column protection or compliance requirements. For this situation, redact or minimize sensitive source fields and validate AI-function data-handling permissions before invocation. The relevant result would be that security review shows only approved fields reach the model and unauthorized analysts cannot retrieve raw PII.

Incorrect Answers

A:

Semi-structured values need explicit conversion before trusted numeric aggregations and calculations. That option implements extract and cast the required VARIANT path into a validated numeric column with error handling. It addresses a different problem; here the distinguishing need is to redact or minimize sensitive source fields and validate AI-function data-handling permissions before invocation.

C:

Array expansion creates line-item rows while a parent key preserves source relationship. That option implements parse the nested array and use an explode operation while retaining the parent event identifier. It addresses a different problem; here the distinguishing need is to redact or minimize sensitive source fields and validate AI-function data-handling permissions before invocation.

D:

VARIANT supports evolving semi-structured values while downstream projections can enforce typed contracts. That option implements store flexible semi-structured payloads in a VARIANT column with intentional extraction of queried paths. It addresses a different problem; here the distinguishing need is to redact or minimize sensitive source fields and validate AI-function data-handling permissions before invocation.

Question 141

An engineer expects a streaming table to automatically apply all historical corrections from a mutable source.

Which pipeline design is most appropriate for this workload?

  1. Define a Lakeflow streaming table reading an incremental streaming source
  2. Choose a materialized view or an explicit CDC design when the source requires updates and retractions
  3. Define both dependent datasets in a Lakeflow pipeline and let data dependencies establish execution order
  4. Assign a single supported pipeline owner and checkpoint strategy for each streaming target

Explanation

Correct Answer

B:

Append-oriented streaming ingestion alone does not encode which prior target rows must be replaced. For this situation, choose a materialized view or an explicit CDC design when the source requires updates and retractions. The relevant result would be that a test source update changes the existing target key instead of leaving duplicate revisions.

Incorrect Answers

A:

Streaming tables process new source changes incrementally and track pipeline state across updates. That option implements define a Lakeflow streaming table reading an incremental streaming source. It addresses a different problem; here the distinguishing need is to choose a materialized view or an explicit CDC design when the source requires updates and retractions.

C:

Declarative dependency analysis schedules downstream computation after required upstream results are available. That option implements define both dependent datasets in a Lakeflow pipeline and let data dependencies establish execution order. It addresses a different problem; here the distinguishing need is to choose a materialized view or an explicit CDC design when the source requires updates and retractions.

D:

Competing writers and inconsistent state tracking can undermine incremental consistency and ownership. That option implements assign a single supported pipeline owner and checkpoint strategy for each streaming target. It addresses a different problem; here the distinguishing need is to choose a materialized view or an explicit CDC design when the source requires updates and retractions.

Question 142

A global sales organization must enforce one agreed definition of active subscriptions across reports.

Which reporting validation establishes correct metric semantics?

  1. Different dashboards return consistent values for a reference fixture and cite the same metric definition
  2. Monthly reports show the correct closing balance without adding balances across time periods
  3. Reference scenarios with multi-item orders reconcile to the approved order-level totals
  4. The documented metric change produces expected reference totals and dependent reports use the approved version

Explanation

Correct Answer

A:

This directly verifies the intended outcome: different dashboards return consistent values for a reference fixture and cite the same metric definition. Central metric definitions let consumers reuse governed calculations instead of independently interpreting KPI formulas. Merely seeing a green job status does not establish that the stated business condition holds.

Incorrect Answers

B:

This would test a different behavior, chiefly model periodic snapshot facts at the defined observation date rather than summing transactions as if they were balances. A balance is a point-in-time semi-additive measure and requires snapshot-aware aggregation. The specific evidence needed here is that different dashboards return consistent values for a reference fixture and cite the same metric definition.

C:

This would test a different behavior, chiefly document the fact-table grain and choose aggregations that respect that grain. Metrics are correct only when counting and summing at the intended business event level. The specific evidence needed here is that different dashboards return consistent values for a reference fixture and cite the same metric definition.

D:

This would test a different behavior, chiefly version and validate the governed metric definition with representative reconciliation tests. Metric governance requires controlled semantic changes and evidence that historical and new calculations are understood. The specific evidence needed here is that different dashboards return consistent values for a reference fixture and cite the same metric definition.

Question 143

A compliance user deletes a few records and assumes logically deleted rows vanish immediately from all object versions.

Which table-maintenance approach best addresses this workload?

  1. Optimize the affected Delta table to compact small files into more efficient scan units
  2. Prefer supported Unity Catalog managed tables with automated maintenance where data-governance requirements permit
  3. Plan physical data purging and retention-aware cleanup after logical deletion under the supported Delta procedure
  4. Use a supported Delta table configuration with deletion vectors where appropriate

Explanation

Correct Answer

C:

Logical delete and deletion vectors do not automatically erase every older physical file or retained version. For this situation, plan physical data purging and retention-aware cleanup after logical deletion under the supported Delta procedure. The relevant result would be that after prescribed retention and purge, prohibited record bytes are no longer accessible through supported historical reads.

Incorrect Answers

A:

File compaction reduces file-opening overhead and improves pruning and read efficiency for many small files. That option implements optimize the affected Delta table to compact small files into more efficient scan units. It addresses a different problem; here the distinguishing need is to plan physical data purging and retention-aware cleanup after logical deletion under the supported Delta procedure.

B:

Managed tables allow platform automation of storage optimization and lifecycle operations that reduce operational overhead. That option implements prefer supported Unity Catalog managed tables with automated maintenance where data-governance requirements permit. It addresses a different problem; here the distinguishing need is to plan physical data purging and retention-aware cleanup after logical deletion under the supported Delta procedure.

D:

Deletion vectors can represent row-level modifications without immediately rewriting whole data files. That option implements use a supported Delta table configuration with deletion vectors where appropriate. It addresses a different problem; here the distinguishing need is to plan physical data purging and retention-aware cleanup after logical deletion under the supported Delta procedure.

Question 144

A customer cohort query returns few rows but reads almost an entire multi-terabyte table.

Which optimization is most defensible from the symptoms?

  1. Inspect query profile and file statistics to tune selective predicates and table layout
  2. Investigate key skew and apply supported skew-aware join or salting strategies where justified
  3. Tune shuffle partitioning and memory strategy based on Spark UI spill and task-size evidence
  4. Use a broadcast join for an appropriately small and safe dimension when profiling supports it

Explanation

Correct Answer

A:

Poor filter pushdown or clustering can force unnecessary scans even when result cardinality is small. For this situation, inspect query profile and file statistics to tune selective predicates and table layout. The relevant result would be that the tuned query uses effective file/data skipping and returns the same cohort records.

Incorrect Answers

B:

Skew creates a few oversized shuffle partitions that dominate stage completion time. That option implements investigate key skew and apply supported skew-aware join or salting strategies where justified. It addresses a different problem; here the distinguishing need is to inspect query profile and file statistics to tune selective predicates and table layout.

C:

Oversized shuffle partitions cause memory pressure; tuning should follow observed stage behavior. That option implements tune shuffle partitioning and memory strategy based on Spark UI spill and task-size evidence. It addresses a different problem; here the distinguishing need is to inspect query profile and file statistics to tune selective predicates and table layout.

D:

Broadcasting a small relation avoids a large shuffle join when memory and size constraints allow. That option implements use a broadcast join for an appropriately small and safe dimension when profiling supports it. It addresses a different problem; here the distinguishing need is to inspect query profile and file statistics to tune selective predicates and table layout.

Question 145

A merge fails because multiple change-feed rows match one target customer key in the same batch.

Which Delta change-processing action best handles these records?

  1. Preprocess source changes to one deterministic applicable record per key before MERGE
  2. Use a Delta MERGE with stable matching keys and explicit matched/update and not-matched/insert logic
  3. Choose the target record using source sequence ordering rather than ingestion arrival order
  4. Handle matched deletes in a keyed MERGE or CDC processing step according to the source contract

Explanation

Correct Answer

A:

Ambiguous many-to-one source matches can make updates incorrect or fail; source ordering resolves the intended record. For this situation, preprocess source changes to one deterministic applicable record per key before MERGE. The relevant result would be that a fixture with repeated customer updates produces the latest correct value and one target key.

Incorrect Answers

B:

MERGE applies conditional updates and inserts transactionally against identified target rows. That option implements use a Delta MERGE with stable matching keys and explicit matched/update and not-matched/insert logic. It addresses a different problem; here the distinguishing need is to preprocess source changes to one deterministic applicable record per key before MERGE.

C:

Arrival time can differ from source transaction order, so state reconciliation needs source ordering. That option implements choose the target record using source sequence ordering rather than ingestion arrival order. It addresses a different problem; here the distinguishing need is to preprocess source changes to one deterministic applicable record per key before MERGE.

D:

Delete markers must map to target removals instead of being inserted as ordinary rows. That option implements handle matched deletes in a keyed MERGE or CDC processing step according to the source contract. It addresses a different problem; here the distinguishing need is to preprocess source changes to one deterministic applicable record per key before MERGE.

Question 146

A healthcare Lakeflow table stops updating after a source field type change.

Which event-log evidence best establishes the cause or result?

  1. The suspect update displays a clear duration regression relative to the approved baseline
  2. The investigation shows either zero newly arrived input or a specific unprocessed backlog with the flow state
  3. A known invalid input increases the recorded expectation-failure count for the correct dataset update
  4. A test schema conflict appears with the affected dataset and disappears after the correct fix

Explanation

Correct Answer

D:

This directly verifies the intended outcome: a test schema conflict appears with the affected dataset and disappears after the correct fix. Pipeline event records capture errors and contextual flow metadata useful for targeted remediation. Merely seeing a green job status does not establish that the stated business condition holds.

Incorrect Answers

A:

This would test a different behavior, chiefly compare pipeline event-log update durations and flow metrics across relevant versions. Time-indexed pipeline events reveal changed throughput and stage timing around a deployment. The specific evidence needed here is that a test schema conflict appears with the affected dataset and disappears after the correct fix.

B:

This would test a different behavior, chiefly check flow-progress events and recent pipeline update status against source-arrival expectations. Progress records distinguish an idle-but-healthy source from a stalled processing component. The specific evidence needed here is that a test schema conflict appears with the affected dataset and disappears after the correct fix.

C:

This would test a different behavior, chiefly query the Lakeflow pipeline event log for update events and data-quality expectation metrics. Event logs expose pipeline progress and expectation outcomes that aggregate job success may hide. The specific evidence needed here is that a test schema conflict appears with the affected dataset and disappears after the correct fix.

Question 147

A credit risk team wants end-of-month positions as distinct from cumulative transaction-flow measures.

Which reporting validation establishes correct metric semantics?

  1. Different dashboards return consistent values for a reference fixture and cite the same metric definition
  2. The documented metric change produces expected reference totals and dependent reports use the approved version
  3. Reference scenarios with multi-item orders reconcile to the approved order-level totals
  4. Monthly reports show the correct closing balance without adding balances across time periods

Explanation

Correct Answer

D:

This directly verifies the intended outcome: monthly reports show the correct closing balance without adding balances across time periods. A balance is a point-in-time semi-additive measure and requires snapshot-aware aggregation. Merely seeing a green job status does not establish that the stated business condition holds.

Incorrect Answers

A:

This would test a different behavior, chiefly define governed Unity Catalog metric views or semantic metrics for shared measures and dimensions. Central metric definitions let consumers reuse governed calculations instead of independently interpreting KPI formulas. The specific evidence needed here is that monthly reports show the correct closing balance without adding balances across time periods.

B:

This would test a different behavior, chiefly version and validate the governed metric definition with representative reconciliation tests. Metric governance requires controlled semantic changes and evidence that historical and new calculations are understood. The specific evidence needed here is that monthly reports show the correct closing balance without adding balances across time periods.

C:

This would test a different behavior, chiefly document the fact-table grain and choose aggregations that respect that grain. Metrics are correct only when counting and summing at the intended business event level. The specific evidence needed here is that monthly reports show the correct closing balance without adding balances across time periods.

Question 148

A location service correlates device events but retains keys for events that can never match again.

Which throughput or state metric proves that it helped?

  1. The post-change table shows a healthier file-size distribution and improved query latency
  2. State size stabilizes under a long replay and within-tolerance late records still join as expected
  3. Microbatch input scan size follows new arrival volume and totals match a full independent reference calculation
  4. Peak arrival tests show the backlog draining and processing rate staying above ingress rate

Explanation

Correct Answer

B:

This directly verifies the intended outcome: state size stabilizes under a long replay and within-tolerance late records still join as expected. Watermarks allow Spark to evict expired streaming state without discarding permissible late events. Merely seeing a green job status does not establish that the stated business condition holds.

Incorrect Answers

A:

This would test a different behavior, chiefly apply appropriate streaming write settings and compaction or managed optimization to control file size. Large numbers of small files add metadata and I/O overhead to downstream scans. The specific evidence needed here is that state size stabilizes under a long replay and within-tolerance late records still join as expected.

C:

This would test a different behavior, chiefly use supported incremental stateful aggregation with checkpointed progress instead of repeated full historical reads. Incremental processing updates state for new events rather than repeatedly transforming all prior source data. The specific evidence needed here is that state size stabilizes under a long replay and within-tolerance late records still join as expected.

D:

This would test a different behavior, chiefly profile the streaming bottleneck and increase sustained processing throughput before tuning the trigger interval. Backlog only shrinks when processing capacity exceeds input arrival rate over time. The specific evidence needed here is that state size stabilizes under a long replay and within-tolerance late records still join as expected.

Question 149

A data engineer created a correct ABAC mask but reads still fail on an old unsupported compute runtime.

Which central fine-grained access policy should be applied?

  1. Create Unity Catalog ABAC masking policies scoped to governed tags at the appropriate catalog or schema
  2. Apply an ABAC row-filter policy driven by governed region tags and an identity-aware UDF
  3. Define governed tags with limited assignment permissions before relying on tag-scoped ABAC
  4. Use a supported serverless or compatible runtime/access configuration for ABAC policy enforcement

Explanation

Correct Answer

D:

Fine-grained ABAC restrictions have compute prerequisites and cannot be assumed to work on all older runtimes. For this situation, use a supported serverless or compatible runtime/access configuration for ABAC policy enforcement. The relevant result would be that the same filtered query succeeds on eligible compute and unauthorized data remains concealed.

Incorrect Answers

A:

Tag-conditioned ABAC policies provide centralized reusable protection as new matching columns appear. That option implements create Unity Catalog ABAC masking policies scoped to governed tags at the appropriate catalog or schema. It addresses a different problem; here the distinguishing need is to use a supported serverless or compatible runtime/access configuration for ABAC policy enforcement.

B:

Row-filter policies evaluate authorized rows at query time across all matching governed objects. That option implements apply an ABAC row-filter policy driven by governed region tags and an identity-aware UDF. It addresses a different problem; here the distinguishing need is to use a supported serverless or compatible runtime/access configuration for ABAC policy enforcement.

C:

ABAC policy selection depends on governed tags that are controlled independently of ordinary write access. That option implements define governed tags with limited assignment permissions before relying on tag-scoped ABAC. It addresses a different problem; here the distinguishing need is to use a supported serverless or compatible runtime/access configuration for ABAC policy enforcement.

Question 150

A platform engineer needs to identify the exact task attempt, retry and failure details of a Lakeflow Job.

Which programmatic or profiling result best supports the resolution?

  1. The proposed change improves the originally dominant operator rather than just reducing total row count
  2. The failed task and exception are identified and a targeted repair succeeds without rerunning good upstream tasks
  3. The command lists only resources accessible to the service identity and reports their latest update status
  4. The profile identifies the dominant shuffle or skewed stage and its cost decreases after correction

Explanation

Correct Answer

B:

This directly verifies the intended outcome: the failed task and exception are identified and a targeted repair succeeds without rerunning good upstream tasks. Task-level run metadata pinpoints failed attempts and environmental errors hidden by a summary status. Merely seeing a green job status does not establish that the stated business condition holds.

Incorrect Answers

A:

This would test a different behavior, chiefly inspect the SQL query profile for scan volumes, shuffles, joins and spill information. Operator-level profiling distinguishes inefficient data access from downstream aggregation work. The specific evidence needed here is that the failed task and exception are identified and a targeted repair succeeds without rerunning good upstream tasks.

C:

This would test a different behavior, chiefly use the Databricks CLI or SDK with approved permissions to list pipeline metadata and updates. Supported automation interfaces expose resource state consistently for deployment and monitoring tools. The specific evidence needed here is that the failed task and exception are identified and a targeted repair succeeds without rerunning good upstream tasks.

D:

This would test a different behavior, chiefly open Spark UI and query profile to examine stages, shuffle and task skew. Execution profiling reveals the costly operators and task distribution that are not evident from business output rows. The specific evidence needed here is that the failed task and exception are identified and a targeted repair succeeds without rerunning good upstream tasks.

Certified Data Engineer Professional Practice Tests

Purchase Individually

  • Premium File

    339 Questions & Answers
    Last Update: Oct 28, 2026

    $76.99
    $69.99
  • Training Course

    33 Lectures

    $43.99
    $39.99

SPECIAL OFFER: GET 10% OFF
This is ONE TIME OFFER

You save
10%

Enter Your Email Address to Receive Your 10% Off Discount Code

SPECIAL OFFER: GET 10% OFF

You save
10%

Use Discount Code:

A confirmation link was sent to your e-mail.

Please check your mailbox for a message from support@examlabs.com and follow the directions.

Download Free Demo of VCE Exam Simulator

Experience Avanset VCE Exam Simulator for yourself.

Simply submit your email address below to get started with our interactive software demo of your free trial.

  • Realistic exam simulation and exam editor with preview functions
  • Whole exam in a single file with several different question types
  • Customizable exam-taking mode & detailed score reports