TableCommitCoordinatorClient¶

TableCommitCoordinatorClient is a wrapper around CommitCoordinatorClient that provides a more user-friendly API for committing and accessing commits to a delta table.

Creating Instance¶

TableCommitCoordinatorClient takes the following to be created:

• CommitCoordinatorClient
• Log Path (of a delta table)
• Table Configuration
• Configuration (Apache Hadoop)
• LogStore

TableCommitCoordinatorClient is created when:

• CatalogOwnedTableUtils is requested to populateTableCommitCoordinatorFromCatalog
• CoordinatedCommitsUtils is requested to getTableCommitCoordinator
• TableCommitCoordinatorClient factory is used to apply

Create TableCommitCoordinatorClient¶

apply(
  commitCoordinatorClient: CommitCoordinatorClient,
  deltaLog: DeltaLog,
  coordinatedCommitsTableConf: Map[String, String]): TableCommitCoordinatorClient

apply requests the given DeltaLog for a newDeltaHadoopConf.

In the end, apply creates a TableCommitCoordinatorClient.

apply is used when:

• OptimisticTransactionImpl is requested to commitLarge and writeCommitFile