org.apache.hadoop.hive.metastore

Class HiveMetaStore

java.lang.Object

org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore

org.apache.hadoop.hive.metastore.HiveMetaStore

public class HiveMetaStore
extends ThriftHiveMetastore

TODO:pc remove application logic to a separate interface.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HiveMetaStore.HiveMetastoreCli HiveMetaStore specific CLI
static class	HiveMetaStore.HMSHandler

Nested classes/interfaces inherited from class org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore

ThriftHiveMetastore.abort_txn_args, ThriftHiveMetastore.abort_txn_result, ThriftHiveMetastore.add_dynamic_partitions_args, ThriftHiveMetastore.add_dynamic_partitions_result, ThriftHiveMetastore.add_index_args, ThriftHiveMetastore.add_index_result, ThriftHiveMetastore.add_partition_args, ThriftHiveMetastore.add_partition_result, ThriftHiveMetastore.add_partition_with_environment_context_args, ThriftHiveMetastore.add_partition_with_environment_context_result, ThriftHiveMetastore.add_partitions_args, ThriftHiveMetastore.add_partitions_pspec_args, ThriftHiveMetastore.add_partitions_pspec_result, ThriftHiveMetastore.add_partitions_req_args, ThriftHiveMetastore.add_partitions_req_result, ThriftHiveMetastore.add_partitions_result, ThriftHiveMetastore.alter_database_args, ThriftHiveMetastore.alter_database_result, ThriftHiveMetastore.alter_function_args, ThriftHiveMetastore.alter_function_result, ThriftHiveMetastore.alter_index_args, ThriftHiveMetastore.alter_index_result, ThriftHiveMetastore.alter_partition_args, ThriftHiveMetastore.alter_partition_result, ThriftHiveMetastore.alter_partition_with_environment_context_args, ThriftHiveMetastore.alter_partition_with_environment_context_result, ThriftHiveMetastore.alter_partitions_args, ThriftHiveMetastore.alter_partitions_result, ThriftHiveMetastore.alter_table_args, ThriftHiveMetastore.alter_table_result, ThriftHiveMetastore.alter_table_with_cascade_args, ThriftHiveMetastore.alter_table_with_cascade_result, ThriftHiveMetastore.alter_table_with_environment_context_args, ThriftHiveMetastore.alter_table_with_environment_context_result, ThriftHiveMetastore.append_partition_args, ThriftHiveMetastore.append_partition_by_name_args, ThriftHiveMetastore.append_partition_by_name_result, ThriftHiveMetastore.append_partition_by_name_with_environment_context_args, ThriftHiveMetastore.append_partition_by_name_with_environment_context_result, ThriftHiveMetastore.append_partition_result, ThriftHiveMetastore.append_partition_with_environment_context_args, ThriftHiveMetastore.append_partition_with_environment_context_result, ThriftHiveMetastore.AsyncClient, ThriftHiveMetastore.AsyncIface, ThriftHiveMetastore.cancel_delegation_token_args, ThriftHiveMetastore.cancel_delegation_token_result, ThriftHiveMetastore.check_lock_args, ThriftHiveMetastore.check_lock_result, ThriftHiveMetastore.Client, ThriftHiveMetastore.commit_txn_args, ThriftHiveMetastore.commit_txn_result, ThriftHiveMetastore.compact_args, ThriftHiveMetastore.compact_result, ThriftHiveMetastore.create_database_args, ThriftHiveMetastore.create_database_result, ThriftHiveMetastore.create_function_args, ThriftHiveMetastore.create_function_result, ThriftHiveMetastore.create_role_args, ThriftHiveMetastore.create_role_result, ThriftHiveMetastore.create_table_args, ThriftHiveMetastore.create_table_result, ThriftHiveMetastore.create_table_with_environment_context_args, ThriftHiveMetastore.create_table_with_environment_context_result, ThriftHiveMetastore.create_type_args, ThriftHiveMetastore.create_type_result, ThriftHiveMetastore.delete_partition_column_statistics_args, ThriftHiveMetastore.delete_partition_column_statistics_result, ThriftHiveMetastore.delete_table_column_statistics_args, ThriftHiveMetastore.delete_table_column_statistics_result, ThriftHiveMetastore.drop_database_args, ThriftHiveMetastore.drop_database_result, ThriftHiveMetastore.drop_function_args, ThriftHiveMetastore.drop_function_result, ThriftHiveMetastore.drop_index_by_name_args, ThriftHiveMetastore.drop_index_by_name_result, ThriftHiveMetastore.drop_partition_args, ThriftHiveMetastore.drop_partition_by_name_args, ThriftHiveMetastore.drop_partition_by_name_result, ThriftHiveMetastore.drop_partition_by_name_with_environment_context_args, ThriftHiveMetastore.drop_partition_by_name_with_environment_context_result, ThriftHiveMetastore.drop_partition_result, ThriftHiveMetastore.drop_partition_with_environment_context_args, ThriftHiveMetastore.drop_partition_with_environment_context_result, ThriftHiveMetastore.drop_partitions_req_args, ThriftHiveMetastore.drop_partitions_req_result, ThriftHiveMetastore.drop_role_args, ThriftHiveMetastore.drop_role_result, ThriftHiveMetastore.drop_table_args, ThriftHiveMetastore.drop_table_result, ThriftHiveMetastore.drop_table_with_environment_context_args, ThriftHiveMetastore.drop_table_with_environment_context_result, ThriftHiveMetastore.drop_type_args, ThriftHiveMetastore.drop_type_result, ThriftHiveMetastore.exchange_partition_args, ThriftHiveMetastore.exchange_partition_result, ThriftHiveMetastore.fire_listener_event_args, ThriftHiveMetastore.fire_listener_event_result, ThriftHiveMetastore.get_aggr_stats_for_args, ThriftHiveMetastore.get_aggr_stats_for_result, ThriftHiveMetastore.get_all_databases_args, ThriftHiveMetastore.get_all_databases_result, ThriftHiveMetastore.get_all_tables_args, ThriftHiveMetastore.get_all_tables_result, ThriftHiveMetastore.get_config_value_args, ThriftHiveMetastore.get_config_value_result, ThriftHiveMetastore.get_current_notificationEventId_args, ThriftHiveMetastore.get_current_notificationEventId_result, ThriftHiveMetastore.get_database_args, ThriftHiveMetastore.get_database_result, ThriftHiveMetastore.get_databases_args, ThriftHiveMetastore.get_databases_result, ThriftHiveMetastore.get_delegation_token_args, ThriftHiveMetastore.get_delegation_token_result, ThriftHiveMetastore.get_fields_args, ThriftHiveMetastore.get_fields_result, ThriftHiveMetastore.get_fields_with_environment_context_args, ThriftHiveMetastore.get_fields_with_environment_context_result, ThriftHiveMetastore.get_function_args, ThriftHiveMetastore.get_function_result, ThriftHiveMetastore.get_functions_args, ThriftHiveMetastore.get_functions_result, ThriftHiveMetastore.get_index_by_name_args, ThriftHiveMetastore.get_index_by_name_result, ThriftHiveMetastore.get_index_names_args, ThriftHiveMetastore.get_index_names_result, ThriftHiveMetastore.get_indexes_args, ThriftHiveMetastore.get_indexes_result, ThriftHiveMetastore.get_next_notification_args, ThriftHiveMetastore.get_next_notification_result, ThriftHiveMetastore.get_open_txns_args, ThriftHiveMetastore.get_open_txns_info_args, ThriftHiveMetastore.get_open_txns_info_result, ThriftHiveMetastore.get_open_txns_result, ThriftHiveMetastore.get_part_specs_by_filter_args, ThriftHiveMetastore.get_part_specs_by_filter_result, ThriftHiveMetastore.get_partition_args, ThriftHiveMetastore.get_partition_by_name_args, ThriftHiveMetastore.get_partition_by_name_result, ThriftHiveMetastore.get_partition_column_statistics_args, ThriftHiveMetastore.get_partition_column_statistics_result, ThriftHiveMetastore.get_partition_names_args, ThriftHiveMetastore.get_partition_names_ps_args, ThriftHiveMetastore.get_partition_names_ps_result, ThriftHiveMetastore.get_partition_names_result, ThriftHiveMetastore.get_partition_result, ThriftHiveMetastore.get_partition_with_auth_args, ThriftHiveMetastore.get_partition_with_auth_result, ThriftHiveMetastore.get_partitions_args, ThriftHiveMetastore.get_partitions_by_expr_args, ThriftHiveMetastore.get_partitions_by_expr_result, ThriftHiveMetastore.get_partitions_by_filter_args, ThriftHiveMetastore.get_partitions_by_filter_result, ThriftHiveMetastore.get_partitions_by_names_args, ThriftHiveMetastore.get_partitions_by_names_result, ThriftHiveMetastore.get_partitions_ps_args, ThriftHiveMetastore.get_partitions_ps_result, ThriftHiveMetastore.get_partitions_ps_with_auth_args, ThriftHiveMetastore.get_partitions_ps_with_auth_result, ThriftHiveMetastore.get_partitions_pspec_args, ThriftHiveMetastore.get_partitions_pspec_result, ThriftHiveMetastore.get_partitions_result, ThriftHiveMetastore.get_partitions_statistics_req_args, ThriftHiveMetastore.get_partitions_statistics_req_result, ThriftHiveMetastore.get_partitions_with_auth_args, ThriftHiveMetastore.get_partitions_with_auth_result, ThriftHiveMetastore.get_principals_in_role_args, ThriftHiveMetastore.get_principals_in_role_result, ThriftHiveMetastore.get_privilege_set_args, ThriftHiveMetastore.get_privilege_set_result, ThriftHiveMetastore.get_role_grants_for_principal_args, ThriftHiveMetastore.get_role_grants_for_principal_result, ThriftHiveMetastore.get_role_names_args, ThriftHiveMetastore.get_role_names_result, ThriftHiveMetastore.get_schema_args, ThriftHiveMetastore.get_schema_result, ThriftHiveMetastore.get_schema_with_environment_context_args, ThriftHiveMetastore.get_schema_with_environment_context_result, ThriftHiveMetastore.get_table_args, ThriftHiveMetastore.get_table_column_statistics_args, ThriftHiveMetastore.get_table_column_statistics_result, ThriftHiveMetastore.get_table_names_by_filter_args, ThriftHiveMetastore.get_table_names_by_filter_result, ThriftHiveMetastore.get_table_objects_by_name_args, ThriftHiveMetastore.get_table_objects_by_name_result, ThriftHiveMetastore.get_table_result, ThriftHiveMetastore.get_table_statistics_req_args, ThriftHiveMetastore.get_table_statistics_req_result, ThriftHiveMetastore.get_tables_args, ThriftHiveMetastore.get_tables_result, ThriftHiveMetastore.get_type_all_args, ThriftHiveMetastore.get_type_all_result, ThriftHiveMetastore.get_type_args, ThriftHiveMetastore.get_type_result, ThriftHiveMetastore.getMetaConf_args, ThriftHiveMetastore.getMetaConf_result, ThriftHiveMetastore.grant_privileges_args, ThriftHiveMetastore.grant_privileges_result, ThriftHiveMetastore.grant_revoke_privileges_args, ThriftHiveMetastore.grant_revoke_privileges_result, ThriftHiveMetastore.grant_revoke_role_args, ThriftHiveMetastore.grant_revoke_role_result, ThriftHiveMetastore.grant_role_args, ThriftHiveMetastore.grant_role_result, ThriftHiveMetastore.heartbeat_args, ThriftHiveMetastore.heartbeat_result, ThriftHiveMetastore.heartbeat_txn_range_args, ThriftHiveMetastore.heartbeat_txn_range_result, ThriftHiveMetastore.Iface, ThriftHiveMetastore.isPartitionMarkedForEvent_args, ThriftHiveMetastore.isPartitionMarkedForEvent_result, ThriftHiveMetastore.list_privileges_args, ThriftHiveMetastore.list_privileges_result, ThriftHiveMetastore.list_roles_args, ThriftHiveMetastore.list_roles_result, ThriftHiveMetastore.lock_args, ThriftHiveMetastore.lock_result, ThriftHiveMetastore.markPartitionForEvent_args, ThriftHiveMetastore.markPartitionForEvent_result, ThriftHiveMetastore.open_txns_args, ThriftHiveMetastore.open_txns_result, ThriftHiveMetastore.partition_name_has_valid_characters_args, ThriftHiveMetastore.partition_name_has_valid_characters_result, ThriftHiveMetastore.partition_name_to_spec_args, ThriftHiveMetastore.partition_name_to_spec_result, ThriftHiveMetastore.partition_name_to_vals_args, ThriftHiveMetastore.partition_name_to_vals_result, ThriftHiveMetastore.Processor<I extends ThriftHiveMetastore.Iface>, ThriftHiveMetastore.rename_partition_args, ThriftHiveMetastore.rename_partition_result, ThriftHiveMetastore.renew_delegation_token_args, ThriftHiveMetastore.renew_delegation_token_result, ThriftHiveMetastore.revoke_privileges_args, ThriftHiveMetastore.revoke_privileges_result, ThriftHiveMetastore.revoke_role_args, ThriftHiveMetastore.revoke_role_result, ThriftHiveMetastore.set_aggr_stats_for_args, ThriftHiveMetastore.set_aggr_stats_for_result, ThriftHiveMetastore.set_ugi_args, ThriftHiveMetastore.set_ugi_result, ThriftHiveMetastore.setMetaConf_args, ThriftHiveMetastore.setMetaConf_result, ThriftHiveMetastore.show_compact_args, ThriftHiveMetastore.show_compact_result, ThriftHiveMetastore.show_locks_args, ThriftHiveMetastore.show_locks_result, ThriftHiveMetastore.unlock_args, ThriftHiveMetastore.unlock_result, ThriftHiveMetastore.update_partition_column_statistics_args, ThriftHiveMetastore.update_partition_column_statistics_result, ThriftHiveMetastore.update_table_column_statistics_args, ThriftHiveMetastore.update_table_column_statistics_result

Field Summary

Fields

Modifier and Type	Field and Description
static String	ADMIN
static org.apache.commons.logging.Log	LOG
static ThreadLocal<DateFormat>	PARTITION_DATE_FORMAT A fixed date format to be used for hive partition column values.
static String	PUBLIC

Constructor Summary

Constructors

Constructor and Description
HiveMetaStore()

Method Summary

Methods

Modifier and Type	Method and Description
static void	cancelDelegationToken(String tokenStrForm) Discard a current delegation token.
static String	getDelegationToken(String owner, String renewer) Get a new delegation token.
static boolean	isMetaStoreRemote()
static void	main(String[] args)
static IHMSHandler	newRetryingHMSHandler(IHMSHandler baseHandler, HiveConf hiveConf)
static IHMSHandler	newRetryingHMSHandler(IHMSHandler baseHandler, HiveConf hiveConf, boolean local)
static ThriftHiveMetastore.Iface	newRetryingHMSHandler(String name, HiveConf conf, boolean local)
static long	renewDelegationToken(String tokenStrForm) Renew a delegation token to extend its lifetime.
static void	startMetaStore(int port, HadoopThriftAuthBridge bridge) Start Metastore based on a passed HadoopThriftAuthBridge
static void	startMetaStore(int port, HadoopThriftAuthBridge bridge, HiveConf conf) Start the metastore store.
static void	startMetaStore(int port, HadoopThriftAuthBridge bridge, HiveConf conf, Lock startLock, Condition startCondition, AtomicBoolean startedServing) Start Metastore based on a passed HadoopThriftAuthBridge

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG

PARTITION_DATE_FORMAT

public static final ThreadLocal<DateFormat> PARTITION_DATE_FORMAT

A fixed date format to be used for hive partition column values.

ADMIN

public static final String ADMIN

See Also:

Constant Field Values

PUBLIC

public static final String PUBLIC

See Also:

Constant Field Values

Constructor Detail

HiveMetaStore

public HiveMetaStore()

Method Detail

newRetryingHMSHandler

public static IHMSHandler newRetryingHMSHandler(IHMSHandler baseHandler,
                                HiveConf hiveConf)
                                         throws MetaException

Throws:

MetaException

newRetryingHMSHandler

public static IHMSHandler newRetryingHMSHandler(IHMSHandler baseHandler,
                                HiveConf hiveConf,
                                boolean local)
                                         throws MetaException

Throws:

MetaException

newRetryingHMSHandler

public static ThriftHiveMetastore.Iface newRetryingHMSHandler(String name,
                                              HiveConf conf,
                                              boolean local)
                                                       throws MetaException

Throws:

MetaException

cancelDelegationToken

public static void cancelDelegationToken(String tokenStrForm)
                                  throws IOException

Discard a current delegation token.

Parameters:

tokenStrForm - the token in string form

Throws:

IOException

getDelegationToken

public static String getDelegationToken(String owner,
                        String renewer)
                                 throws IOException,
                                        InterruptedException

Get a new delegation token.

Parameters:

renewer - the designated renewer

Throws:

IOException

InterruptedException

isMetaStoreRemote

public static boolean isMetaStoreRemote()

Returns:

true if remote metastore has been created

renewDelegationToken

public static long renewDelegationToken(String tokenStrForm)
                                 throws IOException

Renew a delegation token to extend its lifetime.

Parameters:

tokenStrForm - the token in string form

Throws:

IOException

main

public static void main(String[] args)
                 throws Throwable

Parameters:

args -

Throws:

Throwable

startMetaStore

public static void startMetaStore(int port,
                  HadoopThriftAuthBridge bridge)
                           throws Throwable

Start Metastore based on a passed HadoopThriftAuthBridge

Parameters:

port -

bridge -

Throws:

Throwable

startMetaStore

public static void startMetaStore(int port,
                  HadoopThriftAuthBridge bridge,
                  HiveConf conf)
                           throws Throwable

Start the metastore store.

Parameters:

port -

bridge -

conf -

Throws:

Throwable

startMetaStore

public static void startMetaStore(int port,
                  HadoopThriftAuthBridge bridge,
                  HiveConf conf,
                  Lock startLock,
                  Condition startCondition,
                  AtomicBoolean startedServing)
                           throws Throwable

Start Metastore based on a passed HadoopThriftAuthBridge

Parameters:

port -

bridge -

conf - configuration overrides

Throws:

Throwable