CheckpointHook¶

CheckpointHook is a post-commit hook to run a checkpoint.

Name¶

PostCommitHook

name: String

name is part of the PostCommitHook abstraction.

name is the following:

Post commit checkpoint trigger

Executing Post-Commit Hook¶

PostCommitHook

run(
  spark: SparkSession,
  txn: OptimisticTransactionImpl,
  committedVersion: Long,
  postCommitSnapshot: Snapshot,
  committedActions: Seq[Action]): Unit

run is part of the PostCommitHook abstraction.

Noop when needsCheckpoint flag disabled

run does nothing when needsCheckpoint flag of the given OptimisticTransactionImpl is disabled.

run ensureLogDirectoryExist.

run requests the DeltaLog for the state snapshot (for the given committedVersion) to checkpoint.