pyflink.table.catalog.HiveCatalog#
- class HiveCatalog(catalog_name: str, default_database: Optional[str] = None, hive_conf_dir: Optional[str] = None, hadoop_conf_dir: Optional[str] = None, hive_version: Optional[str] = None)[source]#
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_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_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_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_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_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_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_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.
partition_exists
(table_path, partition_spec)Check whether a partition exists or not.
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.