Câu 98: Databricks Certified Data Engineer Professional

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 promotion, and they would like to add 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?

1. A. Specify a new checkpointLocation — đáp án hiện tại
2. B. Increase the shuffle partitions to account for additional aggregates
3. C. Run REFRESH TABLE delta.'/item_agg'
4. D. Register the data in the "/item_agg" directory to the Hive metastore
5. E. Remove .option(‘mergeSchema’, ‘true’) from the streaming write