Databricks Certified Data Engineer - Professional
Get started today
Ultimate access to all questions.
Comments
Loading comments...
Ultimate access to all questions.
When executing the following query on the Delta table 'customers' with Change Data Feed enabled, what describes the results each time the query is run?
.option("readChangeFeed", "true")
.option("startingVersion", 0)
.table("customers")
.filter(col("_change_type").isin(["update_postimage"]))
.writeStream
.option("checkpointLocation", "dbfs:/checkpoints")
.trigger(availableNow=True)
.table("customers_updates")
.option("readChangeFeed", "true")
.option("startingVersion", 0)
.table("customers")
.filter(col("_change_type").isin(["update_postimage"]))
.writeStream
.option("checkpointLocation", "dbfs:/checkpoints")
.trigger(availableNow=True)
.table("customers_updates")
A
Newly updated records will be merged into the target table, modifying previous entries with the same primary keys.
B
Newly updated records will overwrite the target table.
C
The entire history of updated records will be appended to the target table at each execution, which leads to duplicate entries.
D
Newly updated records will be appended to the target table.
E
The entire history of updated records will overwrite the target table at each execution.