Как я могу создать контрольную точку вручную при использовании дельты озера?

Question

Как создать контрольную точку вручную, когда я записываю данные пакета по формату («дельта») на спарк? Как мы все знаем, Delta Lake создаст контрольную точку автоматически на 10 версий. Но как запустить создание контрольной точки, как мы хотим?

Answer 1

import org.apache.spark.sql.delta.DeltaLog

DeltaLog.forTable (spark, dataPath) .checkpoint ()