Databricks Certified Data Engineer - Professional
Get started today
Ultimate access to all questions.
Comments
Loading comments...
Ultimate access to all questions.
The data engineering team maintains a Delta Lake table named 'daily_activities', which is completely overwritten each night with new data from the source system. For auditing purposes, they aim to use Delta Lake's Time Travel functionality to identify differences between the new and previous versions of the table. After retrieving the current table version with the code: current_version = spark.sql('SELECT max(version) FROM (DESCRIBE HISTORY daily_activities)').collect()[0][0], which query should they use to accomplish this task?_
A
SELECT * FROM daily_activities UNION SELECT * FROM daily_activities AS VERSION = {current_version-1}_
B
SELECT * FROM daily_activities INTERSECT SELECT * FROM daily_activities AS VERSION = {current_version-1}_
C
SELECT * FROM daily_activities EXCEPT SELECT * FROM daily_activities@v{current_version-1}_
D
SELECT * FROM daily_activities MINUS SELECT * FROM daily_activities AS VERSION = {current_version-1}_
E
SELECT * FROM daily_activities UNION ALL SELECT * FROM daily_activities@v{current_version-1}_