@InterfaceAudience.Private public interface IHMSHandler extends ThriftHiveMetastore.Iface, org.apache.hadoop.conf.Configurable
Modifier and Type | Method and Description |
---|---|
Database |
get_database_core(String catName,
String name)
Equivalent to get_database, but does not write to audit logs, or fire pre-event listeners.
|
Table |
get_table_core(String catName,
String dbname,
String name)
Equivalent of get_table, but does not log audits and fire pre-event listener.
|
List<MetaStoreEventListener> |
getListeners()
Get a list of all non-transactional listeners.
|
RawStore |
getMS()
Get a reference to the underlying RawStore.
|
int |
getThreadId()
Get the id of the thread of this handler.
|
List<TransactionalMetaStoreEventListener> |
getTransactionalListeners()
Get a list of all transactional listeners.
|
TxnStore |
getTxnHandler()
Get a reference to the underlying TxnStore.
|
Warehouse |
getWh()
Get a reference to Hive's warehouse object (the class that does all the physical operations).
|
void |
init() |
abort_txn, abort_txns, add_check_constraint, add_default_constraint, add_dynamic_partitions, add_foreign_key, add_master_key, add_not_null_constraint, add_partition_with_environment_context, add_partition, add_partitions_pspec, add_partitions_req, add_partitions, add_primary_key, add_runtime_stats, add_schema_version, add_serde, add_token, add_unique_constraint, allocate_table_write_ids, alter_catalog, alter_database, alter_function, alter_ischema, alter_partition_with_environment_context, alter_partition, alter_partitions_with_environment_context, alter_partitions, alter_resource_plan, alter_table_with_cascade, alter_table_with_environment_context, alter_table, alter_wm_pool, alter_wm_trigger, append_partition_by_name_with_environment_context, append_partition_by_name, append_partition_with_environment_context, append_partition, cache_file_metadata, cancel_delegation_token, check_lock, clear_file_metadata, cm_recycle, commit_txn, compact, compact2, create_catalog, create_database, create_function, create_ischema, create_or_drop_wm_trigger_to_pool_mapping, create_or_update_wm_mapping, create_resource_plan, create_role, create_table_with_constraints, create_table_with_environment_context, create_table, create_type, create_wm_pool, create_wm_trigger, delete_partition_column_statistics, delete_table_column_statistics, drop_catalog, drop_constraint, drop_database, drop_function, drop_ischema, drop_partition_by_name_with_environment_context, drop_partition_by_name, drop_partition_with_environment_context, drop_partition, drop_partitions_req, drop_resource_plan, drop_role, drop_schema_version, drop_table_with_environment_context, drop_table, drop_type, drop_wm_mapping, drop_wm_pool, drop_wm_trigger, exchange_partition, exchange_partitions, fire_listener_event, flushCache, get_active_resource_plan, get_aggr_stats_for, get_all_databases, get_all_functions, get_all_resource_plans, get_all_tables, get_all_token_identifiers, get_catalog, get_catalogs, get_check_constraints, get_config_value, get_current_notificationEventId, get_database, get_databases, get_default_constraints, get_delegation_token, get_fields_with_environment_context, get_fields, get_file_metadata_by_expr, get_file_metadata, get_foreign_keys, get_function, get_functions, get_ischema, get_lock_materialization_rebuild, get_master_keys, get_materialization_invalidation_info, get_materialized_views_for_rewriting, get_metastore_db_uuid, get_next_notification, get_not_null_constraints, get_notification_events_count, get_num_partitions_by_filter, get_open_txns_info, get_open_txns, get_part_specs_by_filter, get_partition_by_name, get_partition_column_statistics, get_partition_names_ps, get_partition_names, get_partition_values, get_partition_with_auth, get_partition, get_partitions_by_expr, get_partitions_by_filter, get_partitions_by_names, get_partitions_ps_with_auth, get_partitions_ps, get_partitions_pspec, get_partitions_statistics_req, get_partitions_with_auth, get_partitions, get_primary_keys, get_principals_in_role, get_privilege_set, get_resource_plan, get_role_grants_for_principal, get_role_names, get_runtime_stats, get_schema_all_versions, get_schema_latest_version, get_schema_version, get_schema_with_environment_context, get_schema, get_schemas_by_cols, get_serde, get_table_column_statistics, get_table_meta, get_table_names_by_filter, get_table_objects_by_name_req, get_table_objects_by_name, get_table_req, get_table_statistics_req, get_table, get_tables_by_type, get_tables, get_token, get_triggers_for_resourceplan, get_type_all, get_type, get_unique_constraints, get_valid_write_ids, getMetaConf, grant_privileges, grant_revoke_privileges, grant_revoke_role, grant_role, heartbeat_lock_materialization_rebuild, heartbeat_txn_range, heartbeat, isPartitionMarkedForEvent, list_privileges, list_roles, lock, map_schema_version_to_serde, markPartitionForEvent, open_txns, partition_name_has_valid_characters, partition_name_to_spec, partition_name_to_vals, put_file_metadata, refresh_privileges, remove_master_key, remove_token, rename_partition, renew_delegation_token, repl_tbl_writeid_state, revoke_privileges, revoke_role, set_aggr_stats_for, set_schema_version_state, set_ugi, setMetaConf, show_compact, show_locks, truncate_table, unlock, update_creation_metadata, update_master_key, update_partition_column_statistics, update_table_column_statistics, validate_resource_plan
void init() throws MetaException
MetaException
int getThreadId()
RawStore getMS() throws MetaException
MetaException
- if the creation of a new RawStore object is necessary but fails.TxnStore getTxnHandler()
Warehouse getWh()
Database get_database_core(String catName, String name) throws NoSuchObjectException, MetaException
catName
- catalog namename
- database nameNoSuchObjectException
- If the database does not exist.MetaException
- If another error occurs.Table get_table_core(String catName, String dbname, String name) throws MetaException, NoSuchObjectException
catName
- catalog namedbname
- database namename
- table nameNoSuchObjectException
- If the table does not exist.MetaException
- If another error occurs.List<TransactionalMetaStoreEventListener> getTransactionalListeners()
List<MetaStoreEventListener> getListeners()
Copyright © 2022 The Apache Software Foundation. All rights reserved.