spark.sql("set spark.databricks.delta.autoCompact.enabled = true")
spark.sql("set spark.databricks.delta.optimizeWrite.enabled = true")
https://docs.databricks.com/_static/notebooks/delta/optimize-scala.html
https://docs.databricks.com/delta/optimizations/index.html#compaction-bin-packing
https://databricks.com/blog/2018/07/31/processing-petabytes-of-data-in-seconds-with-databricks-delta.html
No comments:
Post a Comment