org.apache.hadoop.hive.ql.metadata

Class SessionHiveMetaStoreClient

java.lang.Object

org.apache.hadoop.hive.metastore.HiveMetaStoreClient

org.apache.hadoop.hive.ql.metadata.SessionHiveMetaStoreClient

All Implemented Interfaces:

AutoCloseable, IMetaStoreClient

public class SessionHiveMetaStoreClient
extends HiveMetaStoreClient
implements IMetaStoreClient

todo: This need review re: thread safety. Various places (see callsers of SessionState.setCurrentSessionState(SessionState)) pass SessionState to forked threads. Currently it looks like those threads only read metadata but this is fragile. Also, maps (in SessionState) where tempt table metadata is stored are concurrent and so any put/get crosses a memory barrier and so does using most java.util.concurrent.* so the readers of the objects in these maps should have the most recent view of the object. But again, could be fragile.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SessionHiveMetaStoreClient.TempTable This stores partition information for a temp table.

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

HiveMetaStoreClient.MetastoreMapIterable<K,V>

Nested classes/interfaces inherited from interface org.apache.hadoop.hive.metastore.IMetaStoreClient

IMetaStoreClient.IncompatibleMetastoreException, IMetaStoreClient.NotificationFilter

Field Summary

Fields inherited from class org.apache.hadoop.hive.metastore.HiveMetaStoreClient

conf, TEST_VERSION, VERSION

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hive.metastore.api.Partition	add_partition(org.apache.hadoop.hive.metastore.api.Partition partition) Loading Dynamic Partitons calls this.
void	alter_table_with_environmentContext(String dbname, String tbl_name, org.apache.hadoop.hive.metastore.api.Table new_tbl, org.apache.hadoop.hive.metastore.api.EnvironmentContext envContext) Alter a table.
void	alter_table(String dbname, String tbl_name, org.apache.hadoop.hive.metastore.api.Table new_tbl) Alter a table
void	alter_table(String dbname, String tbl_name, org.apache.hadoop.hive.metastore.api.Table new_tbl, boolean cascade) Deprecated.
protected void	create_table_with_environment_context(org.apache.hadoop.hive.metastore.api.Table tbl, org.apache.hadoop.hive.metastore.api.EnvironmentContext envContext)
boolean	deleteTableColumnStatistics(String dbName, String tableName, String colName) Delete table level column statistics given dbName, tableName and colName, or all columns in a table.
protected void	drop_table_with_environment_context(String catName, String dbname, String name, boolean deleteData, org.apache.hadoop.hive.metastore.api.EnvironmentContext envContext)
org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet	get_privilege_set(org.apache.hadoop.hive.metastore.api.HiveObjectRef hiveObject, String userName, List<String> groupNames) Return the privileges that the user, group have directly and indirectly through roles on the given hiveObject
List<String>	getAllTables(String dbName) Get the names of all tables in the specified database.
List<org.apache.hadoop.hive.metastore.api.Partition>	getPartitionsByNames(String db_name, String tblName, List<String> partNames) partNames are like "p=1/q=2" type strings.
List<org.apache.hadoop.hive.metastore.api.FieldSchema>	getSchema(String dbName, String tableName) Get schema for a table, including the partition columns.
org.apache.hadoop.hive.metastore.api.Table	getTable(String dbname, String name) Get a table object in the default catalog.
org.apache.hadoop.hive.metastore.api.Table	getTable(String catName, String dbName, String tableName) Get a table object.
List<org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj>	getTableColumnStatistics(String dbName, String tableName, List<String> colNames) Get the column statistics for a set of columns in a table.
List<org.apache.hadoop.hive.metastore.api.TableMeta>	getTableMeta(String dbPatterns, String tablePatterns, List<String> tableTypes) Fetches just table name and comments.
List<org.apache.hadoop.hive.metastore.api.Table>	getTableObjectsByName(String dbName, List<String> tableNames) Get tables as objects (rather than just fetching their names).
List<String>	getTables(String dbName, String tablePattern) Get the names of all tables in the specified database that satisfy the supplied table name pattern.
static Map<String,Table>	getTempTablesForDatabase(String dbName, String tblName)
List<String>	listPartitionNames(String dbName, String tableName, short maxParts) Returns a list of partition names, i.e.
List<org.apache.hadoop.hive.metastore.api.Partition>	listPartitionsWithAuthInfo(String dbName, String tableName, List<String> partialPvals, short maxParts, String userName, List<String> groupNames) List partitions along with privilege information for a user or groups
boolean	setPartitionColumnStatistics(org.apache.hadoop.hive.metastore.api.SetPartitionsStatsRequest request) Set table or partition column statistics.
boolean	tableExists(String databaseName, String tableName) Check whether a table exists in the default catalog.
void	truncateTable(String dbName, String tableName, List<String> partNames) Truncate the table/partitions in the DEFAULT database.

Methods inherited from class org.apache.hadoop.hive.metastore.HiveMetaStoreClient

abortTxns, add_partition, add_partitions_pspec, add_partitions, add_partitions, addCheckConstraint, addDefaultConstraint, addDynamicPartitions, addDynamicPartitions, addForeignKey, addMasterKey, addNotNullConstraint, addPrimaryKey, addRuntimeStat, addSchemaVersion, addSerDe, addToken, addUniqueConstraint, allocateTableWriteId, allocateTableWriteIdsBatch, alter_partition, alter_partition, alter_partition, alter_partitions, alter_partitions, alter_partitions, alter_table, alterCatalog, alterDatabase, alterDatabase, alterFunction, alterFunction, alterISchema, alterResourcePlan, alterWMPool, alterWMTrigger, appendPartition, appendPartition, appendPartition, appendPartition, appendPartition, appendPartitionByName, appendPartitionByName, cacheFileMetadata, cancelDelegationToken, checkLock, clearFileMetadata, close, commitTxn, compact, compact, compact2, create_role, createCatalog, createDatabase, createFunction, createISchema, createOrDropTriggerToPoolMapping, createOrUpdateWMMapping, createResourcePlan, createTable, createTable, createTableWithConstraints, createType, createWMPool, createWMTrigger, deepCopy, deepCopy, deepCopy, deepCopyFieldSchemas, deletePartitionColumnStatistics, deletePartitionColumnStatistics, deleteTableColumnStatistics, drop_role, dropCatalog, dropConstraint, dropConstraint, dropDatabase, dropDatabase, dropDatabase, dropDatabase, dropFunction, dropFunction, dropISchema, dropPartition, dropPartition, dropPartition, dropPartition, dropPartition, dropPartition, dropPartition, dropPartition, dropPartition, dropPartitionByName, dropPartitionByName, dropPartitions, dropPartitions, dropPartitions, dropPartitions, dropResourcePlan, dropSchemaVersion, dropTable, dropTable, dropTable, dropTable, dropTable, dropType, dropWMMapping, dropWMPool, dropWMTrigger, exchange_partition, exchange_partition, exchange_partitions, exchange_partitions, fireListenerEvent, flushCache, get_principals_in_role, get_role_grants_for_principal, getActiveResourcePlan, getAggrColStatsFor, getAggrColStatsFor, getAllDatabases, getAllDatabases, getAllFunctions, getAllResourcePlans, getAllTables, getAllTokenIdentifiers, getCatalog, getCatalogs, getCheckConstraints, getConfigValue, getCurrentNotificationEventId, getDatabase, getDatabase, getDatabases, getDatabases, getDefaultConstraints, getDelegationToken, getDelegationToken, getFields, getFields, getFileMetadata, getFileMetadataBySarg, getForeignKeys, getFunction, getFunction, getFunctions, getFunctions, getISchema, getMasterKeys, getMaterializationInvalidationInfo, getMaterializedViewsForRewriting, getMaterializedViewsForRewriting, getMetaConf, getMetastoreDbUuid, getNextNotification, getNotificationEventsCount, getNotNullConstraints, getNumPartitionsByFilter, getNumPartitionsByFilter, getPartition, getPartition, getPartition, getPartition, getPartitionColumnStatistics, getPartitionColumnStatistics, getPartitionsByNames, getPartitionWithAuthInfo, getPartitionWithAuthInfo, getPrimaryKeys, getResourcePlan, getRuntimeStats, getSchema, getSchemaAllVersions, getSchemaByCols, getSchemaLatestVersion, getSchemaVersion, getSerDe, getTableColumnStatistics, getTableMeta, getTableObjectsByName, getTables, getTables, getTables, getToken, getTokenStrForm, getTriggersForResourcePlan, getTTransport, getType, getTypeAll, getUniqueConstraints, getValidTxns, getValidTxns, getValidWriteIds, getValidWriteIds, grant_privileges, grant_role, heartbeat, heartbeatLockMaterializationRebuild, heartbeatTxnRange, insertTable, isCompatibleWith, isLocalMetaStore, isPartitionMarkedForEvent, isPartitionMarkedForEvent, isSameConfObj, list_privileges, list_roles, listPartitionNames, listPartitionNames, listPartitionNames, listPartitions, listPartitions, listPartitions, listPartitions, listPartitionsByExpr, listPartitionsByExpr, listPartitionsByFilter, listPartitionsByFilter, listPartitionSpecs, listPartitionSpecs, listPartitionSpecsByFilter, listPartitionSpecsByFilter, listPartitionsWithAuthInfo, listPartitionsWithAuthInfo, listPartitionsWithAuthInfo, listPartitionValues, listRoleNames, listTableNamesByFilter, listTableNamesByFilter, lock, lockMaterializationRebuild, mapSchemaVersionToSerde, markPartitionForEvent, markPartitionForEvent, newSynchronizedClient, openTxn, openTxns, partitionNameToSpec, partitionNameToVals, putFileMetadata, reconnect, recycleDirToCmPath, refresh_privileges, removeMasterKey, removeToken, renamePartition, renamePartition, renewDelegationToken, replAllocateTableWriteIdsBatch, replCommitTxn, replOpenTxn, replRollbackTxn, replTableWriteIdState, revoke_privileges, revoke_role, rollbackTxn, setHiveAddedJars, setMetaConf, setSchemaVersionState, showCompactions, showLocks, showLocks, showTxns, tableExists, truncateTable, unlock, updateCreationMetadata, updateCreationMetadata, updateMasterKey, updatePartitionColumnStatistics, updateTableColumnStatistics, validatePartitionNameCharacters, validateResourcePlan

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hive.metastore.IMetaStoreClient

abortTxns, add_partitions_pspec, add_partitions, add_partitions, addCheckConstraint, addDefaultConstraint, addDynamicPartitions, addDynamicPartitions, addForeignKey, addMasterKey, addNotNullConstraint, addPrimaryKey, addRuntimeStat, addSchemaVersion, addSerDe, addToken, addUniqueConstraint, allocateTableWriteId, allocateTableWriteIdsBatch, alter_partition, alter_partition, alter_partition, alter_partition, alter_partitions, alter_partitions, alter_partitions, alter_partitions, alter_table, alter_table, alterCatalog, alterDatabase, alterDatabase, alterFunction, alterFunction, alterISchema, alterResourcePlan, alterWMPool, alterWMTrigger, appendPartition, appendPartition, appendPartition, appendPartition, cacheFileMetadata, cancelDelegationToken, checkLock, clearFileMetadata, close, commitTxn, compact, compact, compact2, create_role, createCatalog, createDatabase, createFunction, createISchema, createOrDropTriggerToPoolMapping, createOrUpdateWMMapping, createResourcePlan, createTable, createTableWithConstraints, createWMPool, createWMTrigger, deletePartitionColumnStatistics, deletePartitionColumnStatistics, deleteTableColumnStatistics, drop_role, dropCatalog, dropConstraint, dropConstraint, dropDatabase, dropDatabase, dropDatabase, dropDatabase, dropDatabase, dropDatabase, dropFunction, dropFunction, dropISchema, dropPartition, dropPartition, dropPartition, dropPartition, dropPartition, dropPartition, dropPartitions, dropPartitions, dropPartitions, dropPartitions, dropPartitions, dropPartitions, dropResourcePlan, dropSchemaVersion, dropTable, dropTable, dropTable, dropTable, dropTable, dropTable, dropWMMapping, dropWMPool, dropWMTrigger, exchange_partition, exchange_partition, exchange_partitions, exchange_partitions, fireListenerEvent, flushCache, get_principals_in_role, get_role_grants_for_principal, getActiveResourcePlan, getAggrColStatsFor, getAggrColStatsFor, getAllDatabases, getAllDatabases, getAllFunctions, getAllResourcePlans, getAllTables, getAllTokenIdentifiers, getCatalog, getCatalogs, getCheckConstraints, getConfigValue, getCurrentNotificationEventId, getDatabase, getDatabase, getDatabases, getDatabases, getDefaultConstraints, getDelegationToken, getFields, getFields, getFileMetadata, getFileMetadataBySarg, getForeignKeys, getFunction, getFunction, getFunctions, getFunctions, getISchema, getMasterKeys, getMaterializationInvalidationInfo, getMaterializedViewsForRewriting, getMaterializedViewsForRewriting, getMetaConf, getMetastoreDbUuid, getNextNotification, getNotificationEventsCount, getNotNullConstraints, getNumPartitionsByFilter, getNumPartitionsByFilter, getPartition, getPartition, getPartition, getPartition, getPartitionColumnStatistics, getPartitionColumnStatistics, getPartitionsByNames, getPartitionWithAuthInfo, getPartitionWithAuthInfo, getPrimaryKeys, getResourcePlan, getRuntimeStats, getSchema, getSchemaAllVersions, getSchemaByCols, getSchemaLatestVersion, getSchemaVersion, getSerDe, getTableColumnStatistics, getTableMeta, getTableObjectsByName, getTables, getTables, getTables, getToken, getTokenStrForm, getTriggersForResourcePlan, getUniqueConstraints, getValidTxns, getValidTxns, getValidWriteIds, getValidWriteIds, grant_privileges, grant_role, heartbeat, heartbeatLockMaterializationRebuild, heartbeatTxnRange, insertTable, isCompatibleWith, isLocalMetaStore, isPartitionMarkedForEvent, isPartitionMarkedForEvent, isSameConfObj, list_privileges, list_roles, listPartitionNames, listPartitionNames, listPartitionNames, listPartitions, listPartitions, listPartitions, listPartitions, listPartitionsByExpr, listPartitionsByExpr, listPartitionsByFilter, listPartitionsByFilter, listPartitionSpecs, listPartitionSpecs, listPartitionSpecsByFilter, listPartitionSpecsByFilter, listPartitionsWithAuthInfo, listPartitionsWithAuthInfo, listPartitionsWithAuthInfo, listPartitionValues, listRoleNames, listTableNamesByFilter, listTableNamesByFilter, lock, lockMaterializationRebuild, mapSchemaVersionToSerde, markPartitionForEvent, markPartitionForEvent, openTxn, openTxns, partitionNameToSpec, partitionNameToVals, putFileMetadata, reconnect, recycleDirToCmPath, refresh_privileges, removeMasterKey, removeToken, renamePartition, renamePartition, renewDelegationToken, replAllocateTableWriteIdsBatch, replCommitTxn, replOpenTxn, replRollbackTxn, replTableWriteIdState, revoke_privileges, revoke_role, rollbackTxn, setHiveAddedJars, setMetaConf, setSchemaVersionState, showCompactions, showLocks, showLocks, showTxns, tableExists, truncateTable, unlock, updateCreationMetadata, updateCreationMetadata, updateMasterKey, updatePartitionColumnStatistics, updateTableColumnStatistics, validatePartitionNameCharacters, validateResourcePlan

Method Detail

create_table_with_environment_context

protected void create_table_with_environment_context(org.apache.hadoop.hive.metastore.api.Table tbl,
                                                     org.apache.hadoop.hive.metastore.api.EnvironmentContext envContext)
                                              throws org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                                                     org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                                     org.apache.hadoop.hive.metastore.api.MetaException,
                                                     org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                     org.apache.thrift.TException

Overrides:

create_table_with_environment_context in class HiveMetaStoreClient

Throws:

org.apache.hadoop.hive.metastore.api.AlreadyExistsException

org.apache.hadoop.hive.metastore.api.InvalidObjectException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.hadoop.hive.metastore.api.NoSuchObjectException

org.apache.thrift.TException

drop_table_with_environment_context

protected void drop_table_with_environment_context(String catName,
                                                   String dbname,
                                                   String name,
                                                   boolean deleteData,
                                                   org.apache.hadoop.hive.metastore.api.EnvironmentContext envContext)
                                            throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                   org.apache.thrift.TException,
                                                   org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                   UnsupportedOperationException

Overrides:

drop_table_with_environment_context in class HiveMetaStoreClient

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

org.apache.hadoop.hive.metastore.api.NoSuchObjectException

UnsupportedOperationException

truncateTable

public void truncateTable(String dbName,
                          String tableName,
                          List<String> partNames)
                   throws org.apache.hadoop.hive.metastore.api.MetaException,
                          org.apache.thrift.TException

Description copied from interface: IMetaStoreClient

Truncate the table/partitions in the DEFAULT database.

Specified by:

truncateTable in interface IMetaStoreClient

Overrides:

truncateTable in class HiveMetaStoreClient

Parameters:

dbName - The db to which the table to be truncate belongs to

tableName - The table to truncate

partNames - List of partitions to truncate. NULL will truncate the whole table/all partitions

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - Failure in the RDBMS or storage

org.apache.thrift.TException - Thrift transport exception

getTable

public org.apache.hadoop.hive.metastore.api.Table getTable(String dbname,
                                                           String name)
                                                    throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                           org.apache.thrift.TException,
                                                           org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Description copied from interface: IMetaStoreClient

Get a table object in the default catalog.

Specified by:

getTable in interface IMetaStoreClient

Overrides:

getTable in class HiveMetaStoreClient

Parameters:

dbname - The database the table is located in.

name - Name of the table to fetch.

Returns:

An object representing the table.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - Could not fetch the table

org.apache.thrift.TException - A thrift communication error occurred

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - In case the table wasn't found.

getTable

public org.apache.hadoop.hive.metastore.api.Table getTable(String catName,
                                                           String dbName,
                                                           String tableName)
                                                    throws org.apache.thrift.TException

Description copied from interface: IMetaStoreClient

Get a table object.

Specified by:

getTable in interface IMetaStoreClient

Overrides:

getTable in class HiveMetaStoreClient

Parameters:

catName - catalog the table is in.

dbName - database the table is in.

tableName - table name.

Returns:

table object.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - Something went wrong, usually in the RDBMS.

org.apache.thrift.TException - general thrift error.

getAllTables

public List<String> getAllTables(String dbName)
                          throws org.apache.hadoop.hive.metastore.api.MetaException

Description copied from interface: IMetaStoreClient

Get the names of all tables in the specified database.

Specified by:

getAllTables in interface IMetaStoreClient

Overrides:

getAllTables in class HiveMetaStoreClient

Parameters:

dbName - database name

Returns:

List of table names.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - something went wrong with the fetch from the RDBMS

getTables

public List<String> getTables(String dbName,
                              String tablePattern)
                       throws org.apache.hadoop.hive.metastore.api.MetaException

Description copied from interface: IMetaStoreClient

Get the names of all tables in the specified database that satisfy the supplied table name pattern.

Specified by:

getTables in interface IMetaStoreClient

Overrides:

getTables in class HiveMetaStoreClient

Parameters:

dbName - database name.

tablePattern - pattern for table name to conform to

Returns:

List of table names.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - error fetching information from the RDBMS

getTableMeta

public List<org.apache.hadoop.hive.metastore.api.TableMeta> getTableMeta(String dbPatterns,
                                                                         String tablePatterns,
                                                                         List<String> tableTypes)
                                                                  throws org.apache.hadoop.hive.metastore.api.MetaException

Description copied from interface: IMetaStoreClient

Fetches just table name and comments. Useful when you need full table name (catalog.database.table) but don't need extra information like partition columns that require additional fetches from the database.

Specified by:

getTableMeta in interface IMetaStoreClient

Overrides:

getTableMeta in class HiveMetaStoreClient

Parameters:

dbPatterns - database pattern to match, or null for all databases

tablePatterns - table pattern to match.

tableTypes - list of table types to fetch.

Returns:

list of TableMeta objects with information on matching tables

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - something went wrong with the fetch from the RDBMS

getTableObjectsByName

public List<org.apache.hadoop.hive.metastore.api.Table> getTableObjectsByName(String dbName,
                                                                              List<String> tableNames)
                                                                       throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                              org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                                                                              org.apache.hadoop.hive.metastore.api.UnknownDBException,
                                                                              org.apache.thrift.TException

Description copied from interface: IMetaStoreClient

Get tables as objects (rather than just fetching their names). This is more expensive and should only be used if you actually need all the information about the tables.

Specified by:

getTableObjectsByName in interface IMetaStoreClient

Overrides:

getTableObjectsByName in class HiveMetaStoreClient

Parameters:

dbName - The database the tables are located in.

tableNames - The names of the tables to fetch

Returns:

A list of objects representing the tables. Only the tables that can be retrieved from the database are returned. For example, if none of the requested tables could be retrieved, an empty list is returned. There is no guarantee of ordering of the returned tables.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - Any other errors

org.apache.hadoop.hive.metastore.api.InvalidOperationException - The input to this operation is invalid (e.g., the list of tables names is null)

org.apache.hadoop.hive.metastore.api.UnknownDBException - The requested database could not be fetched.

org.apache.thrift.TException - A thrift communication error occurred

tableExists

public boolean tableExists(String databaseName,
                           String tableName)
                    throws org.apache.hadoop.hive.metastore.api.MetaException,
                           org.apache.thrift.TException,
                           org.apache.hadoop.hive.metastore.api.UnknownDBException

Description copied from interface: IMetaStoreClient

Check whether a table exists in the default catalog.

Specified by:

tableExists in interface IMetaStoreClient

Overrides:

tableExists in class HiveMetaStoreClient

Parameters:

databaseName - database name

tableName - table name

Returns:

true if the indicated table exists, false if not

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - error fetching form the RDBMS

org.apache.thrift.TException - thrift transport error

org.apache.hadoop.hive.metastore.api.UnknownDBException - the indicated database does not exist.

getSchema

public List<org.apache.hadoop.hive.metastore.api.FieldSchema> getSchema(String dbName,
                                                                        String tableName)
                                                                 throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                        org.apache.thrift.TException,
                                                                        org.apache.hadoop.hive.metastore.api.UnknownTableException,
                                                                        org.apache.hadoop.hive.metastore.api.UnknownDBException

Description copied from interface: IMetaStoreClient

Get schema for a table, including the partition columns.

Specified by:

getSchema in interface IMetaStoreClient

Overrides:

getSchema in class HiveMetaStoreClient

Parameters:

dbName - database name

tableName - table name

Returns:

list of field schemas describing the table's schema

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - error accessing the RDBMS

org.apache.hadoop.hive.metastore.api.UnknownTableException - no such table

org.apache.hadoop.hive.metastore.api.UnknownDBException - no such database

org.apache.thrift.TException - thrift transport error

alter_table

@Deprecated
public void alter_table(String dbname,
                                    String tbl_name,
                                    org.apache.hadoop.hive.metastore.api.Table new_tbl,
                                    boolean cascade)
                             throws org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                                    org.apache.hadoop.hive.metastore.api.MetaException,
                                    org.apache.thrift.TException

Deprecated.

Specified by:

alter_table in interface IMetaStoreClient

Overrides:

alter_table in class HiveMetaStoreClient

Throws:

org.apache.hadoop.hive.metastore.api.InvalidOperationException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

alter_table

public void alter_table(String dbname,
                        String tbl_name,
                        org.apache.hadoop.hive.metastore.api.Table new_tbl)
                 throws org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                        org.apache.hadoop.hive.metastore.api.MetaException,
                        org.apache.thrift.TException

Description copied from interface: IMetaStoreClient

Alter a table

Specified by:

alter_table in interface IMetaStoreClient

Overrides:

alter_table in class HiveMetaStoreClient

Parameters:

dbname - database name

tbl_name - table name

new_tbl - new table object, should be complete representation of the table, not just the things you want to change.

Throws:

org.apache.hadoop.hive.metastore.api.InvalidOperationException - something is wrong with the new table object or an operation was attempted that is not allowed (such as changing partition columns).

org.apache.hadoop.hive.metastore.api.MetaException - something went wrong, usually in the RDBMS

org.apache.thrift.TException - general thrift exception

alter_table_with_environmentContext

public void alter_table_with_environmentContext(String dbname,
                                                String tbl_name,
                                                org.apache.hadoop.hive.metastore.api.Table new_tbl,
                                                org.apache.hadoop.hive.metastore.api.EnvironmentContext envContext)
                                         throws org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                                                org.apache.hadoop.hive.metastore.api.MetaException,
                                                org.apache.thrift.TException

Description copied from interface: IMetaStoreClient

Alter a table.

Specified by:

alter_table_with_environmentContext in interface IMetaStoreClient

Overrides:

alter_table_with_environmentContext in class HiveMetaStoreClient

Parameters:

dbname - database name

tbl_name - table name

new_tbl - new table object, should be complete representation of the table, not just the things you want to change.

envContext - options for the alter.

Throws:

org.apache.hadoop.hive.metastore.api.InvalidOperationException - something is wrong with the new table object or an operation was attempted that is not allowed (such as changing partition columns).

org.apache.hadoop.hive.metastore.api.MetaException - something went wrong, usually in the RDBMS

org.apache.thrift.TException - general thrift exception

get_privilege_set

public org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet get_privilege_set(org.apache.hadoop.hive.metastore.api.HiveObjectRef hiveObject,
                                                                                    String userName,
                                                                                    List<String> groupNames)
                                                                             throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                                    org.apache.thrift.TException

Description copied from interface: IMetaStoreClient

Return the privileges that the user, group have directly and indirectly through roles on the given hiveObject

Specified by:

get_privilege_set in interface IMetaStoreClient

Overrides:

get_privilege_set in class HiveMetaStoreClient

Returns:

the privilege set

Throws:

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

setPartitionColumnStatistics

public boolean setPartitionColumnStatistics(org.apache.hadoop.hive.metastore.api.SetPartitionsStatsRequest request)
                                     throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                            org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                            org.apache.hadoop.hive.metastore.api.MetaException,
                                            org.apache.thrift.TException,
                                            org.apache.hadoop.hive.metastore.api.InvalidInputException

Set table or partition column statistics.

Specified by:

setPartitionColumnStatistics in interface IMetaStoreClient

Overrides:

setPartitionColumnStatistics in class HiveMetaStoreClient

Parameters:

request - request object, contains all the table, partition, and statistics information

Returns:

true if the set was successful.

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - the table, partition, or columns specified do not exist.

org.apache.hadoop.hive.metastore.api.InvalidObjectException - the stats object is not valid.

org.apache.hadoop.hive.metastore.api.MetaException - error accessing the RDBMS.

org.apache.thrift.TException - thrift transport error.

org.apache.hadoop.hive.metastore.api.InvalidInputException - the input is invalid (eg, a null table name)

getTableColumnStatistics

public List<org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj> getTableColumnStatistics(String dbName,
                                                                                               String tableName,
                                                                                               List<String> colNames)
                                                                                        throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                                                               org.apache.hadoop.hive.metastore.api.MetaException,
                                                                                               org.apache.thrift.TException,
                                                                                               org.apache.hadoop.hive.metastore.api.InvalidInputException,
                                                                                               org.apache.hadoop.hive.metastore.api.InvalidObjectException

Get the column statistics for a set of columns in a table. This should only be used for non-partitioned tables. For partitioned tables use IMetaStoreClient.getPartitionColumnStatistics(String, String, List, List).

Specified by:

getTableColumnStatistics in interface IMetaStoreClient

Overrides:

getTableColumnStatistics in class HiveMetaStoreClient

Parameters:

dbName - database name

tableName - table name

colNames - list of column names

Returns:

list of column statistics objects, one per column

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no such table

org.apache.hadoop.hive.metastore.api.MetaException - error accessing the RDBMS

org.apache.thrift.TException - thrift transport error

org.apache.hadoop.hive.metastore.api.InvalidInputException

org.apache.hadoop.hive.metastore.api.InvalidObjectException

deleteTableColumnStatistics

public boolean deleteTableColumnStatistics(String dbName,
                                           String tableName,
                                           String colName)
                                    throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                           org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                           org.apache.hadoop.hive.metastore.api.MetaException,
                                           org.apache.thrift.TException,
                                           org.apache.hadoop.hive.metastore.api.InvalidInputException

Delete table level column statistics given dbName, tableName and colName, or all columns in a table. This should be used for non-partitioned tables.

Specified by:

deleteTableColumnStatistics in interface IMetaStoreClient

Overrides:

deleteTableColumnStatistics in class HiveMetaStoreClient

Parameters:

dbName - database name

tableName - table name

colName - column name, or null to drop stats for all columns

Returns:

boolean indicating the outcome of the operation

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - No such table

org.apache.hadoop.hive.metastore.api.InvalidObjectException - error dropping the stats

org.apache.hadoop.hive.metastore.api.MetaException - error accessing the RDBMS

org.apache.thrift.TException - thrift transport error

org.apache.hadoop.hive.metastore.api.InvalidInputException - bad input, like a null table name.

getTempTablesForDatabase

public static Map<String,Table> getTempTablesForDatabase(String dbName,
                                                         String tblName)

Parameters:

dbName - actual database name

tblName - actual table name or search pattern (for error message)

add_partition

public org.apache.hadoop.hive.metastore.api.Partition add_partition(org.apache.hadoop.hive.metastore.api.Partition partition)
                                                             throws org.apache.thrift.TException

Loading Dynamic Partitons calls this. Hive.loadPartition() calls this which in turn can be called from Hive.loadDynamicPartitions() among others

Specified by:

add_partition in interface IMetaStoreClient

Overrides:

add_partition in class HiveMetaStoreClient

Parameters:

partition - The partition to add

Returns:

the partition added

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - Could not find table to add to

org.apache.hadoop.hive.metastore.api.AlreadyExistsException - Partition already exists

org.apache.hadoop.hive.metastore.api.MetaException - Could not add partition

org.apache.thrift.TException - Thrift exception

See Also:

ThriftHiveMetastore.Iface.add_partition(org.apache.hadoop.hive.metastore.api.Partition)

listPartitionsWithAuthInfo

public List<org.apache.hadoop.hive.metastore.api.Partition> listPartitionsWithAuthInfo(String dbName,
                                                                                       String tableName,
                                                                                       List<String> partialPvals,
                                                                                       short maxParts,
                                                                                       String userName,
                                                                                       List<String> groupNames)
                                                                                throws org.apache.thrift.TException

Description copied from interface: IMetaStoreClient

List partitions along with privilege information for a user or groups

Specified by:

listPartitionsWithAuthInfo in interface IMetaStoreClient

Overrides:

listPartitionsWithAuthInfo in class HiveMetaStoreClient

Parameters:

partialPvals - partition values, can be partial. This really means that missing values are represented by empty str.

maxParts - maximum number of partitions to fetch, or -1 for all

dbName - database name

tableName - table name

userName - user to fetch privilege information for

groupNames - group to fetch privilege information for

Returns:

the list of partitions

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no partitions matching the criteria were found

org.apache.hadoop.hive.metastore.api.MetaException - error accessing the RDBMS

org.apache.thrift.TException - thrift transport error

listPartitionNames

public List<String> listPartitionNames(String dbName,
                                       String tableName,
                                       short maxParts)
                                throws org.apache.thrift.TException

Returns a list of partition names, i.e. "p=1/q=2" type strings. The values (RHS of =) are escaped.

Specified by:

listPartitionNames in interface IMetaStoreClient

Overrides:

listPartitionNames in class HiveMetaStoreClient

Parameters:

dbName - database name.

tableName - table name.

maxParts - maximum number of parts of fetch, or -1 to fetch them all.

Returns:

list of partition names.

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - No such table.

org.apache.hadoop.hive.metastore.api.MetaException - Error accessing the RDBMS.

org.apache.thrift.TException - thrift transport error

getPartitionsByNames

public List<org.apache.hadoop.hive.metastore.api.Partition> getPartitionsByNames(String db_name,
                                                                                 String tblName,
                                                                                 List<String> partNames)
                                                                          throws org.apache.thrift.TException

partNames are like "p=1/q=2" type strings. The values (RHS of =) are escaped.

Specified by:

getPartitionsByNames in interface IMetaStoreClient

Overrides:

getPartitionsByNames in class HiveMetaStoreClient

Parameters:

db_name - database name

tblName - table name

partNames - list of partition names

Returns:

list of Partition objects

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - No such partitions

org.apache.hadoop.hive.metastore.api.MetaException - error accessing the RDBMS.

org.apache.thrift.TException - thrift transport error