Tries to re-create the table in the catalog replacing state with the new canonical InternalTable representation and tableIdentifier.

Performs a level-order traversal of the schema and returns a list of all fields. Use this method to get a list that includes nested fields. Use {@link

Returns an implementation class for {@link CatalogTableIdentifier} based on the tableIdentifier provided by user.

Extracts a {@link TableChange} for the provided commit. @param commit commit to capture table changes for. @return {@link TableChange}

Loads the conversion configs. The method first loads the default configs and then merges any custom configs provided by the user. @param customConfig

Syncs the provided snapshot files to the target system. This method is required to both add and remove files. @param partitionedDataFiles the files t

Syncs the current partition spec. @param partitionSpec the current partition spec

Syncs the current schema state. @param schema the current schema

create Glue column from InternalField

Returns an implementation class for {@link CatalogConversionSource} that's used for converting table definitions in the catalog to {@link org.apache.x

Extracts the representation of the deletion vector information corresponding to an AddFile action. Currently, this method extracts and returns the pat

Takes the input map which represents a json object and flattens it. @param statMap input json map @return map with keys representing the dot-path for

Create a test table instance for general testing. The table is created with the schema defined in basic_schema.avsc which contains many data types to

Get Hudi serde properties that needs to be synced with catalog table