pyflink.table.catalog.HiveCatalog

class HiveCatalog(catalog_name: str, default_database: str | None = None, hive_conf_dir: str | None = None, hadoop_conf_dir: str | None = None, hive_version: str | None = None)

A catalog implementation for Hive.

Methods

alter_database(name, new_database, ...)	Modify an existing database.
alter_function(function_path, new_function, ...)	Modify an existing function.
alter_model(model_path, new_model, ...)	Modify an existing model.
alter_partition(table_path, partition_spec, ...)	Alter a partition.
alter_partition_column_statistics(...)	Update the column statistics of a table partition.
alter_partition_statistics(table_path, ...)	Update the statistics of a table partition.
alter_table(table_path, new_table, ...)	Modify an existing table or view.
alter_table_column_statistics(table_path, ...)	Update the column statistics of a table.
alter_table_metadata(table_path, metadata)	Update metadata of the corresponding table, should be merged with stored metadata.
alter_table_statistics(table_path, ...)	Update the statistics of a table.
bulk_get_partition_column_statistics(...)	Get a list of the column statistics for the given partitions.
bulk_get_partition_statistics(table_path, ...)	Get a list of statistics of given partitions.
create_database(name, database, ignore_if_exists)	Create a database.
create_function(function_path, function, ...)	Create a function.
create_model(model_path, model, ignore_if_exists)	Create a new model.
create_partition(table_path, partition_spec, ...)	Create a partition.
create_table(table_path, table, ignore_if_exists)	Create a new table or view.
database_exists(database_name)	Check if a database exists in this catalog.
drop_database(name, ignore_if_exists)	Drop a database.
drop_function(function_path, ...)	Drop a function.
drop_model(model_path, ignore_if_not_exists)	Drop a model.
drop_partition(table_path, partition_spec, ...)	Drop a partition.
drop_table(table_path, ignore_if_not_exists)	Drop a table or view.
function_exists(function_path)	Check whether a function exists or not.
get_database(database_name)	Get a database from this catalog.
get_default_database()	Get the name of the default database for this catalog.
get_function(function_path)	Get the function.
get_model(model_path)	Get the model.
get_partition(table_path, partition_spec)	Get a partition of the given table.
get_partition_column_statistics(table_path, ...)	Get the column statistics of a partition.
get_partition_statistics(table_path, ...)	Get the statistics of a partition.
get_procedure(procedure_path)	Get the procedure.
get_table(table_path)	Get a CatalogTable or CatalogView identified by tablePath.
get_table_column_statistics(table_path)	Get the column statistics of a table.
get_table_metadata(table_path)	Get metadata of the corresponding table.
get_table_statistics(table_path)	Get the statistics of a table.
list_databases()	Get the names of all databases in this catalog.
list_functions(database_name)	List the names of all functions in the given database.
list_models(database_name)	List the names of all models in the given database.
list_partitions(table_path[, partition_spec])	Get CatalogPartitionSpec of all partitions of the table.
list_procedures(database_name)	List the names of all procedures in the given database.
list_tables(database_name)	Get names of all tables and views under this database.
list_views(database_name)	Get names of all views under this database.
model_exists(model_path)	Check whether a model exists or not.
partition_exists(table_path, partition_spec)	Check whether a partition exists or not.
rename_model(model_path, new_model_name, ...)	Rename an existing model.
rename_table(table_path, new_table_name, ...)	Rename an existing table or view.
table_exists(table_path)	Check if a table or view exists in this catalog.