Reputation: 397
Delta Lake creates a checkpoint automatically per 10 version. Is there any way to create checkpoint manually?
Upvotes: 5
Views: 3092
Reputation: 397
import org.apache.spark.sql.delta.DeltaLog
DeltaLog.forTable(spark,dataPath).checkpoint()
Upvotes: 5