lakehouse.databricks.common.rollback_delta_table_by_version

lakehouse.databricks.common.rollback_delta_table_by_version(spark, schema, table, version=None)

A function to truncate all of the Hive tables within a hive database/schema

Parameters

sparkspark context

spark context passed from the calling spark instance

schemastring

The name of the database/schema

tablestring

The name of the table to rollback

version: int, default=None

The version you would like to rollback to, if version param is omitted the table will be rolled back to the prior version