medium10 pts · first answer countssparkdelta-laketime-travel

Reading yesterday's table version

A bad job ran at 10:00 on a Delta table. You want to read the table exactly as it was at version 41, before that job. How?

A.spark.read.option("versionAsOf", 41).table("sales")B.spark.read.table("sales").limit(41)C.spark.read.parquet("sales/_delta_log/41")D.spark.sql("SELECT * FROM sales WHERE version = 41")

Discussion 0

Join free to post in the discussion.

Reading yesterday's table version

Discussion 0

Related questions