nerdexam
DatabricksDatabricks

CERTIFIED-DATA-ENGINEER-PROFESSIONAL · Question #106

CERTIFIED-DATA-ENGINEER-PROFESSIONAL Question #106: Real Exam Question with Answer & Explanation

Sign in or unlock CERTIFIED-DATA-ENGINEER-PROFESSIONAL to reveal the answer and full explanation for question #106. The question stem and answer options stay visible for context.

Building and Managing Streaming Pipelines

Question

A data team's Structured Streaming job is configured to calculate running aggregates for item sales to update a downstream marketing dashboard. The marketing team has introduced a new field to track the number of times this promotion code is used for each item. A junior data engineer suggests updating the existing query as follows: Note that proposed changes are in bold. Original query: Proposed query: Proposed query: .start("/item_agg") Which step must also be completed to put the proposed query into production?

Options

  • AIncrease the shuffle partitions to account for additional aggregates
  • BSpecify a new checkpointlocation
  • CRun REFRESH TABLE delta, /item_agg'
  • DRemove .option (mergeSchema', true') from the streaming write
  • ERegister the data in the "/item_agg" directory to the Hive metastore

Unlock CERTIFIED-DATA-ENGINEER-PROFESSIONAL to see the answer

You've previewed enough free CERTIFIED-DATA-ENGINEER-PROFESSIONAL questions. Unlock CERTIFIED-DATA-ENGINEER-PROFESSIONAL for full answers, explanations, the timed quiz mode, progress tracking, and the master PDF. Question stem and options stay visible so you can still see what's on the exam.

Topics

#Structured Streaming#Checkpointing#Schema Evolution#Streaming Operations
Full CERTIFIED-DATA-ENGINEER-PROFESSIONAL PracticeBrowse All CERTIFIED-DATA-ENGINEER-PROFESSIONAL Questions