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:

IMetaStoreClient

public class SessionHiveMetaStoreClient
extends HiveMetaStoreClient
implements IMetaStoreClient

Nested Class Summary

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, LOG

Method Summary

Methods

Modifier and Type	Method and Description
void	alter_table(String dbname, String tbl_name, Table new_tbl, boolean cascade)
void	alter_table(String dbname, String tbl_name, Table new_tbl, EnvironmentContext envContext)
protected void	create_table_with_environment_context(Table tbl, EnvironmentContext envContext)
boolean	deleteTableColumnStatistics(String dbName, String tableName, String colName) Delete table level column statistics given dbName, tableName and colName
protected void	drop_table_with_environment_context(String dbname, String name, boolean deleteData, EnvironmentContext envContext)
PrincipalPrivilegeSet	get_privilege_set(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<FieldSchema>	getSchema(String dbName, String tableName)
Table	getTable(String dbname, String name) Get a table object.
List<ColumnStatisticsObj>	getTableColumnStatistics(String dbName, String tableName, List<String> colNames) Get table column statistics given dbName, tableName and multiple colName-s
List<Table>	getTableObjectsByName(String dbName, List<String> tableNames)
List<String>	getTables(String dbName, String tablePattern) Get the names of all tables in the specified database that satisfy the supplied table name pattern.
boolean	tableExists(String databaseName, String tableName)
boolean	updateTableColumnStatistics(ColumnStatistics statsObj) Write table level column statistics to persistent store

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

add_partition, add_partition, add_partitions_pspec, add_partitions, add_partitions, addDynamicPartitions, alter_index, alter_partition, alter_partitions, alter_table, alterDatabase, alterFunction, appendPartition, appendPartition, appendPartition, appendPartition, appendPartitionByName, appendPartitionByName, cancelDelegationToken, checkLock, close, commitTxn, compact, create_role, createDatabase, createFunction, createIndex, createTable, createTable, createType, deepCopy, deepCopy, deepCopyFieldSchemas, deletePartitionColumnStatistics, drop_role, dropDatabase, dropDatabase, dropDatabase, dropFunction, dropIndex, dropPartition, dropPartition, dropPartition, dropPartition, dropPartition, dropPartition, dropPartition, dropPartitionByName, dropPartitionByName, dropPartitions, dropPartitions, dropPartitions, dropTable, dropTable, dropTable, dropTable, dropTable, dropType, exchange_partition, fireListenerEvent, get_principals_in_role, get_role_grants_for_principal, getAggrColStatsFor, getAllDatabases, getConfigValue, getCurrentNotificationEventId, getDatabase, getDatabases, getDelegationToken, getDelegationToken, getFields, getFunction, getFunctions, getIndex, getMetaConf, getNextNotification, getPartition, getPartition, getPartitionColumnStatistics, getPartitionsByNames, getPartitionWithAuthInfo, getTable, getTokenStrForm, getType, getTypeAll, getValidTxns, getValidTxns, grant_privileges, grant_role, heartbeat, heartbeatTxnRange, isCompatibleWith, isPartitionMarkedForEvent, list_privileges, list_roles, listIndexes, listIndexNames, listPartitionNames, listPartitionNames, listPartitions, listPartitions, listPartitionsByExpr, listPartitionsByFilter, listPartitionSpecs, listPartitionSpecsByFilter, listPartitionsWithAuthInfo, listPartitionsWithAuthInfo, listRoleNames, listTableNamesByFilter, lock, markPartitionForEvent, newSynchronizedClient, openTxn, openTxns, partitionNameToSpec, partitionNameToVals, reconnect, renamePartition, renewDelegationToken, revoke_privileges, revoke_role, rollbackTxn, setHiveAddedJars, setMetaConf, setPartitionColumnStatistics, showCompactions, showLocks, showTxns, tableExists, unlock, updatePartitionColumnStatistics, validatePartitionNameCharacters

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

add_partition, add_partitions_pspec, add_partitions, add_partitions, addDynamicPartitions, alter_index, alter_partition, alter_partitions, alter_table, alterDatabase, alterFunction, appendPartition, appendPartition, cancelDelegationToken, checkLock, close, commitTxn, compact, create_role, createDatabase, createFunction, createIndex, createTable, deletePartitionColumnStatistics, drop_role, dropDatabase, dropDatabase, dropDatabase, dropFunction, dropIndex, dropPartition, dropPartition, dropPartition, dropPartitions, dropPartitions, dropPartitions, dropTable, dropTable, dropTable, dropTable, exchange_partition, fireListenerEvent, get_principals_in_role, get_role_grants_for_principal, getAggrColStatsFor, getAllDatabases, getConfigValue, getCurrentNotificationEventId, getDatabase, getDatabases, getDelegationToken, getFields, getFunction, getFunctions, getIndex, getMetaConf, getNextNotification, getPartition, getPartition, getPartitionColumnStatistics, getPartitionsByNames, getPartitionWithAuthInfo, getTable, getTokenStrForm, getValidTxns, getValidTxns, grant_privileges, grant_role, heartbeat, heartbeatTxnRange, isCompatibleWith, isPartitionMarkedForEvent, list_privileges, list_roles, listIndexes, listIndexNames, listPartitionNames, listPartitionNames, listPartitions, listPartitions, listPartitionsByExpr, listPartitionsByFilter, listPartitionSpecs, listPartitionSpecsByFilter, listPartitionsWithAuthInfo, listPartitionsWithAuthInfo, listRoleNames, listTableNamesByFilter, lock, markPartitionForEvent, openTxn, openTxns, partitionNameToSpec, partitionNameToVals, reconnect, renamePartition, renewDelegationToken, revoke_privileges, revoke_role, rollbackTxn, setHiveAddedJars, setMetaConf, setPartitionColumnStatistics, showCompactions, showLocks, showTxns, tableExists, unlock, updatePartitionColumnStatistics, validatePartitionNameCharacters

Method Detail

create_table_with_environment_context

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

Overrides:

create_table_with_environment_context in class HiveMetaStoreClient

Throws:

AlreadyExistsException

InvalidObjectException

MetaException

NoSuchObjectException

org.apache.thrift.TException

drop_table_with_environment_context

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

Overrides:

drop_table_with_environment_context in class HiveMetaStoreClient

Throws:

MetaException

org.apache.thrift.TException

NoSuchObjectException

UnsupportedOperationException

getTable

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

Description copied from interface: IMetaStoreClient

Get a table object.

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:

the table

Throws:

MetaException - Could not fetch the table

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

NoSuchObjectException - In case the table wasn't found.

See Also:

ThriftHiveMetastore.Iface.get_table(java.lang.String, java.lang.String)

getAllTables

public List<String> getAllTables(String dbName)
                          throws MetaException

Description copied from class: HiveMetaStoreClient

Get the names of all tables in the specified database.

Specified by:

getAllTables in interface IMetaStoreClient

Overrides:

getAllTables in class HiveMetaStoreClient

Returns:

List of table names.

Throws:

MetaException

getTables

public List<String> getTables(String dbName,
                     String tablePattern)
                       throws MetaException

Description copied from class: HiveMetaStoreClient

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

Returns:

List of table names.

Throws:

MetaException

getTableObjectsByName

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

Description copied from class: HiveMetaStoreClient

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:

MetaException - Any other errors

InvalidOperationException - The input to this operation is invalid (e.g., the list of tables names is null)

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 MetaException,
                           org.apache.thrift.TException,
                           UnknownDBException

Specified by:

tableExists in interface IMetaStoreClient

Overrides:

tableExists in class HiveMetaStoreClient

Throws:

MetaException

org.apache.thrift.TException

UnknownDBException

getSchema

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

Specified by:

getSchema in interface IMetaStoreClient

Overrides:

getSchema in class HiveMetaStoreClient

Throws:

MetaException

UnknownTableException

UnknownDBException

org.apache.thrift.TException

See Also:

ThriftHiveMetastore.Iface.get_schema(java.lang.String, java.lang.String)

alter_table

public void alter_table(String dbname,
               String tbl_name,
               Table new_tbl,
               boolean cascade)
                 throws InvalidOperationException,
                        MetaException,
                        org.apache.thrift.TException

Specified by:

alter_table in interface IMetaStoreClient

Overrides:

alter_table in class HiveMetaStoreClient

Throws:

InvalidOperationException

MetaException

org.apache.thrift.TException

alter_table

public void alter_table(String dbname,
               String tbl_name,
               Table new_tbl,
               EnvironmentContext envContext)
                 throws InvalidOperationException,
                        MetaException,
                        org.apache.thrift.TException

Overrides:

alter_table in class HiveMetaStoreClient

Throws:

InvalidOperationException

MetaException

org.apache.thrift.TException

get_privilege_set

public PrincipalPrivilegeSet get_privilege_set(HiveObjectRef hiveObject,
                                      String userName,
                                      List<String> groupNames)
                                        throws 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:

MetaException

org.apache.thrift.TException

updateTableColumnStatistics

public boolean updateTableColumnStatistics(ColumnStatistics statsObj)
                                    throws NoSuchObjectException,
                                           InvalidObjectException,
                                           MetaException,
                                           org.apache.thrift.TException,
                                           InvalidInputException

Write table level column statistics to persistent store

Specified by:

updateTableColumnStatistics in interface IMetaStoreClient

Overrides:

updateTableColumnStatistics in class HiveMetaStoreClient

Returns:

boolean indicating the status of the operation

Throws:

NoSuchObjectException

InvalidObjectException

MetaException

org.apache.thrift.TException

InvalidInputException

getTableColumnStatistics

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

Get table column statistics given dbName, tableName and multiple colName-s

Specified by:

getTableColumnStatistics in interface IMetaStoreClient

Overrides:

getTableColumnStatistics in class HiveMetaStoreClient

Returns:

ColumnStatistics struct for a given db, table and columns

Throws:

NoSuchObjectException

MetaException

org.apache.thrift.TException

InvalidInputException

InvalidObjectException

deleteTableColumnStatistics

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

Delete table level column statistics given dbName, tableName and colName

Specified by:

deleteTableColumnStatistics in interface IMetaStoreClient

Overrides:

deleteTableColumnStatistics in class HiveMetaStoreClient

Returns:

boolean indicating the outcome of the operation

Throws:

NoSuchObjectException

InvalidObjectException

MetaException

org.apache.thrift.TException

InvalidInputException