Skip to content

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.