Creates a database used by tableIdentifier in the catalog.

Reads the IdTracking information from the provided schema if it is present. @param schema to get IdTracking information from @return Option containin

Syncs the changes in files to the target system. This method is required to both add and remove files. @param internalFilesDiff the diff that needs t

Completes the sync and performs any cleanup required.

Returns the xtable metadata persisted in the target

Extracts partition fields from delta table. Partitioning by nested columns isn't supported. Example: Given a delta table and a reference to DeltaLog,

Starts the sync and performs any initialization required @param table the table that will be synced

Removes the specified partitions from a table in the catalog. @param tableIdentifier an object identifying the table from which partitions are to be

Drops a table from the catalog.

Returns the {@link org.apache.xtable.model.storage.CatalogType} the client syncs to

Checks whether a database used by tableIdentifier exists in the catalog.

Loads the meta client for the table at the base path if it exists @param tableDataPath the path for the table @return {@link HoodieTableMetaClient} i

Updates the properties indicating the last synchronization state for the given table. <p>This method provides a default implementation that performs

Creates a InternalFilesDiff from the list of files in the target table and the list of files in the source table. @param source list of files current

Retrieves the Hadoop configuration. <p>This method creates a new {@code Configuration} instance, reads the Hadoop configuration file path from the se

Creates a table state with the given id so the state is different between calls. @param id id to use in the names of certain fields @return the table

Retrieves the commit identifier from the target table that corresponds to a given source table commit identifier @param sourceIdentifier the unique i

Determines whether an incremental sync is safe from a given instant. This method checks for a couple of things: the existence of a commit at or before

Refreshes the table metadata in the catalog with tableIdentifier.

Adds new partitions to the specified table in the catalog. @param tableIdentifier an object identifying the table where partitions are to be added. @

Compares the latest files with the previous files and identifies the files that are new, i.e. are present in latest files buy not present in the previ

Constructs a new {@code CatalogTableIdentifier} from a hierarchical string identifier. <p>The identifier is expected to be in one of the following fo

Retrieves all partitions associated with the specified table. @param tableIdentifier an object identifying the table whose partitions are to be fetch