Databricks Certified Data Engineer - Professional
Get started today
Ultimate access to all questions.
Comments
Loading comments...
Ultimate access to all questions.
How can a data engineer count all records updated in the source table using Delta Lake's Change Data Feed?
A
spark.read.format("delta") \ .option("readChangeFeed", "true") \ .option("startingVersion", 0) \ .table("source") \ .where(col('_change_type') == 'update_postimage') \ .count()_
B
spark.read.format("delta") \ .option("readChangeFeed", "true") \ .option("startingVersion", 0) \ .table("source") \ .where(col('_change_type') == 'update_preimage') \ .count()_
C
spark.read.format("delta") \ .option("readChangeFeed", "true") \ .option("startingVersion", 0) \ .table("source") \ .where(col('_change_type') == 'update') \ .count()
D
All of the above
E
Both A and B