Databricks Certified Data Engineer - Professional
Get started today
Ultimate access to all questions.
Comments
Loading comments...
Ultimate access to all questions.
To ensure the mobiles table contains only unique entries for auditing purposes, which modification should be made to the following streaming query?
.option('readChangeFeed', 'true')
.table('customers')
.select('mobile')
.writeStream
.format('delta')
.option('checkpointLocation', '/tmp/customers/_checkpoints/')
.table('mobiles')```_
.option('readChangeFeed', 'true')
.table('customers')
.select('mobile')
.writeStream
.format('delta')
.option('checkpointLocation', '/tmp/customers/_checkpoints/')
.table('mobiles')```_
A
Add option('startingVersion', 0) to avoid duplicate entries in the mobiles table.
B
Drop rows where the _change_type column's value is delete or update_postimage._
C
Omit the checkpoint location from the streaming query.
D
Keep only rows with _change_type values of insert, update_postimage, and delete._
E
Drop all rows containing delete and update_preimage in the _change_type column._