lakehouse.databricks.common.repartition_delta_table

lakehouse.databricks.common.repartition_delta_table(spark, schema, table, partitionBy)

A function to repartition a delta table

Parameters

sparkspark context

spark context passed from the calling spark instance

schemastring

The name of the delta db where the table exists

table: string

The name of the delta table to repartition

partitionBy: array

The Columns to be used in the partition scheme