CommitCoordinatorProvider¶

getCommitCoordinatorClientOpt¶

getCommitCoordinatorClientOpt(
  name: String,
  conf: Map[String, String],
  spark: SparkSession): Option[CommitCoordinatorClient]

getCommitCoordinatorClientOpt looks up a CommitCoordinatorBuilder by the given name (in the nameToBuilderMapping lookup table).

If found, getCommitCoordinatorClientOpt requests this CommitCoordinatorBuilder to build a CommitCoordinatorClient.

getCommitCoordinatorClientOpt is used when:

• CommitCoordinatorProvider is requested to getCommitCoordinatorClient
• CoordinatedCommitsUtils is requested to getCommitCoordinatorClient