5

Delta Lake 每 10 个版本自动创建一个检查点。有没有办法手动创建检查点?

4

1 回答 1

5
import org.apache.spark.sql.delta.DeltaLog 
DeltaLog.forTable(spark,dataPath).checkpoint()
于 2019-11-11T07:45:50.493 回答