CommitCoordinatorClient¶

CommitCoordinatorClient is an abstraction of commit coordinator clients that can communicate with a commit coordinator and backfill commits.

Contract¶

backfillToVersion¶

void backfillToVersion(
  LogStore logStore,
  Configuration hadoopConf,
  TableDescriptor tableDescriptor,
  long version,
  Long lastKnownBackfilledVersion) throws IOException

See:

• UCCommitCoordinatorClient

Used when:

• DynamoDBCommitCoordinatorClient is requested to commit
• UCCommitCoordinatorClient is requested to commitImpl and attemptFullBackfill
• AbstractBatchBackfillingCommitCoordinatorClient is requested to commit
• TableCommitCoordinatorClient is requested to backfillToVersion

commit¶

CommitResponse commit(
  LogStore logStore,
  Configuration hadoopConf,
  TableDescriptor tableDescriptor,
  long commitVersion,
  Iterator<String> actions,
  UpdatedActions updatedActions) throws CommitFailedException

See:

• UCCommitCoordinatorClient

Used when:

• TableCommitCoordinatorClient is requested to commit

getCommits¶

GetCommitsResponse getCommits(
  TableDescriptor tableDescriptor,
  Long startVersion,
  Long endVersion)

See:

• UCCommitCoordinatorClient

Used when:

• UCCommitCoordinatorClient is requested to getLastKnownBackfilledVersion and backfillToVersion
• AbstractBatchBackfillingCommitCoordinatorClient is requested to backfillToVersion
• TableCommitCoordinatorClient is requested to getCommits

registerTable¶

Map<String, String> registerTable(
  Path logPath,
  Optional<TableIdentifier> tableIdentifier,
  long currentVersion,
  AbstractMetadata currentMetadata,
  AbstractProtocol currentProtocol)

See:

• UCCommitCoordinatorClient

Used when:

• OptimisticTransactionImpl is requested to registerTableForCoordinatedCommitsIfNeeded

semanticEquals¶

boolean semanticEquals(
  CommitCoordinatorClient other)

See:

• UCCommitCoordinatorClient

Used when:

• CommitCoordinatorClient is requested to semanticEquals

Implementations¶

• AbstractBatchBackfillingCommitCoordinatorClient
• DynamoDBCommitCoordinatorClient
• FileSystemBasedCommitCoordinatorClient
• UCCommitCoordinatorClient

CommitCoordinatorClient.semanticEquals¶

semanticEquals(
  commitCoordinatorClientOpt1: Option[CommitCoordinatorClient],
  commitCoordinatorClientOpt2: Option[CommitCoordinatorClient]): Boolean

semanticEquals...FIXME

semanticEquals is used when:

• TableCommitCoordinatorClient is requested to semanticsEquals