您可以使用下麵的代碼刪除所有時間旅行特性(舊的快照)超過1小時。最好不要使用0小時可以刪除當前編寫和數據一致性問題。如果你不需要酸功能,包括能力做並發寫道,你可以考慮使用拚花。
從三角洲。表導入* spark.conf.set (“spark.databricks.delta.retentionDurationCheck.enabled”,“假”)deltaTable = deltaTable。forPath(火花,deltaPath) deltaTable.vacuum (1)
您可以使用下麵的代碼刪除所有時間旅行特性(舊的快照)超過1小時。最好不要使用0小時可以刪除當前編寫和數據一致性問題。如果你不需要酸功能,包括能力做並發寫道,你可以考慮使用拚花。
從三角洲。表導入* spark.conf.set (“spark.databricks.delta.retentionDurationCheck.enabled”,“假”)deltaTable = deltaTable。forPath(火花,deltaPath) deltaTable.vacuum (1)