Databricks Certified Data Engineer - Professional

Get started today

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?

Real Exam

spark.read.format("delta") \ .option("readChangeFeed", "true") \ .option("startingVersion", 0) \ .table("source") \ .where(col('_change_type') == 'update_postimage') \ .count()_

11.5%

spark.read.format("delta") \ .option("readChangeFeed", "true") \ .option("startingVersion", 0) \ .table("source") \ .where(col('_change_type') == 'update_preimage') \ .count()_

5.7%

Comments

Loading comments...

spark.read.format("delta") \ .option("readChangeFeed", "true") \ .option("startingVersion", 0) \ .table("source") \ .where(col('_change_type') == 'update') \ .count()