All Classes and Interfaces
Class
Description
Interface for objects that represents the base information for a commit.
Interface for Delta domain-metadata actions.
Interface for metadata actions in Delta.
Interface for protocol actions in Delta.
LogStore implementation for Azure.
:: DeveloperApi ::
An iterator that may contain resources which should be released after use.
Representation of a commit file
Raised when UC cannot determine whether the commit at the requested version already landed: the
version is at or below the latest commit, but UC retains no row at it (the row was backfilled and
cleaned up), so UC cannot tell whether the version holds this caller's own commit or a different
writer's.
The CommitCoordinatorClient is responsible for communicating with the commit coordinator
and backfilling commits.
This exception is thrown by the UC client in case UC has reached the maximum
number of commits that it is allowed to track (50 by default).
Thrown by
UCDeltaClient when credential vending exhausts retries.Helper for misc functions relating to file names for delta commits.
The
LogStore implementation for GCS, which uses gcs-connector to
provide the necessary atomic and durability guarantees:
Atomic Visibility: Read/read-after-metadata-update/delete are strongly
consistent for GCS.
Consistent Listing: GCS guarantees strong consistency for both object and
bucket listing operations.Response container for
CommitCoordinatorClient.getCommits(TableDescriptor, Long, Long).Default implementation of
LogStore for Hadoop FileSystem implementations.The
LogStore implementation for HDFS, which uses Hadoop FileContext API's to
provide the necessary atomic and durability guarantees:
Atomic visibility of files: `FileContext.rename` is used write files which is atomic for
HDFS.
Consistent file listing: HDFS file listing is consistent.
Metadata for Delta Uniform Iceberg conversion.
This exception is thrown by the UC client in case a commit attempt tried to add
a UUID-based commit to the wrong table.
Turn a
Reader to CloseableIterator which can be read on demand.Default
LogStore implementation (should be used for testing only!).:: DeveloperApi ::
Thrown by
UCDeltaClient operations when the
catalog reports that the requested table does not exist (HTTP 404).A lock that provides per-file-path `acquire` and `release` semantics.
Static utility methods for the S3SingleDriverLogStore.
Single JVM LogStore implementation for S3.
Container for all the info to uniquely identify the table
Identifier for a table.
Interface for interacting with the Unity Catalog.
Column definition for registering table schema with Unity Catalog.
A commit coordinator client that uses unity-catalog as the commit coordinator.
Base class for all exceptions thrown by the UC client from coordinated commits-related APIs.
Shared utility methods for parsing flat UC configuration maps (e.g.
Class containing usage logs emitted by Coordinated Commits.
Extends
UCClient with Delta table lifecycle operations backed by the UC Delta API
(load, stage, and create tables).Extended response for
CommitCoordinatorClient.getCommits(io.delta.storage.commit.TableDescriptor, java.lang.Long, java.lang.Long) implementations backed by the
Delta REST loadTable API.Delta-owned models for the UC Delta API.
Per-commit metrics payload reported to Unity Catalog.
Post-commit file-size distribution snapshot, reported alongside the commit report.
Result of
UCDeltaClient.loadTable(io.delta.storage.commit.TableIdentifier) / UCDeltaClient.createTable(java.net.URI, io.delta.storage.commit.TableIdentifier, io.delta.storage.commit.uccommitcoordinator.UCDeltaModels.TableType, io.delta.storage.commit.actions.AbstractMetadata, io.delta.storage.commit.actions.AbstractProtocol, java.util.List<io.delta.storage.commit.actions.AbstractDomainMetadata>, long, java.util.Optional<io.delta.storage.commit.uniform.UniformMetadata>).A REST client implementation of
UCDeltaClient that uses the UC Delta API for
all table lifecycle and commit coordination operations.A REST client implementation of
UCClient for interacting with Unity Catalog's commit
coordination service.Metadata for Delta Universal Format (UniForm) conversions.
Thrown when the catalog refuses to serve a non-Delta table.
A container class to inform the CommitCoordinatorClient about any changes in Protocol/Metadata
This exception is thrown by the UC client in case the client attempted an upgrade
of a table to a UC managed table but the upgrade is not allowed because the previous
commit was a downgrade.