org.apache.hadoop.hive.metastore

Class ObjectStore

java.lang.Object

org.apache.hadoop.hive.metastore.ObjectStore

All Implemented Interfaces:

RawStore

public class ObjectStore
extends java.lang.Object
implements RawStore

This class is the interface between the application logic and the database store that contains the objects. Refrain putting any logic in mode.M* objects or in this file as former could be auto generated and this class would need to be made into a interface that can read both from a database and a filestore.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ObjectStore.UpdateMDatabaseURIRetVal
class	ObjectStore.UpdateMStorageDescriptorTblPropURIRetVal
class	ObjectStore.UpdateMStorageDescriptorTblURIRetVal
class	ObjectStore.UpdateSerdeURIRetVal

Constructor Summary

Constructors

Constructor and Description
ObjectStore()

Method Summary

Modifier and Type	Method and Description
boolean	addIndex(Index index)
int	addMasterKey(java.lang.String key)
boolean	addPartition(Partition part)
boolean	addRole(java.lang.String roleName, java.lang.String ownerName)
boolean	addToken(java.lang.String tokenId, java.lang.String delegationToken)
boolean	alterDatabase(java.lang.String dbName, Database db) Alter the database object in metastore.
void	alterIndex(java.lang.String dbname, java.lang.String baseTblName, java.lang.String name, Index newIndex)
void	alterPartition(java.lang.String dbname, java.lang.String name, java.util.List<java.lang.String> part_vals, Partition newPart)
void	alterPartitions(java.lang.String dbname, java.lang.String name, java.util.List<java.util.List<java.lang.String>> part_vals, java.util.List<Partition> newParts)
void	alterTable(java.lang.String dbname, java.lang.String name, Table newTable)
long	cleanupEvents()
boolean	commitTransaction() if this is the commit of the first open call then an actual commit is called.
void	createDatabase(Database db)
void	createTable(Table tbl)
boolean	createType(Type type)
boolean	deletePartitionColumnStatistics(java.lang.String dbName, java.lang.String tableName, java.lang.String partName, java.util.List<java.lang.String> partVals, java.lang.String colName) Deletes column statistics if present associated with a given db, table, partition and col.
boolean	deleteTableColumnStatistics(java.lang.String dbName, java.lang.String tableName, java.lang.String colName) Deletes column statistics if present associated with a given db, table and col.
boolean	dropDatabase(java.lang.String dbname)
boolean	dropIndex(java.lang.String dbName, java.lang.String origTableName, java.lang.String indexName)
boolean	dropPartition(java.lang.String dbName, java.lang.String tableName, java.util.List<java.lang.String> part_vals)
boolean	dropTable(java.lang.String dbName, java.lang.String tableName)
boolean	dropType(java.lang.String typeName)
java.util.Collection<?>	executeJDOQLSelect(java.lang.String query) The following API - executeJDOQLSelect is used by HiveMetaTool.
long	executeJDOQLUpdate(java.lang.String query) The following API - executeJDOQLUpdate is used by HiveMetaTool.
java.util.List<java.lang.String>	getAllDatabases()
java.util.List<java.lang.String>	getAllTables(java.lang.String dbName)
java.util.List<java.lang.String>	getAllTokenIdentifiers()
PrincipalPrivilegeSet	getColumnPrivilegeSet(java.lang.String dbName, java.lang.String tableName, java.lang.String partitionName, java.lang.String columnName, java.lang.String userName, java.util.List<java.lang.String> groupNames)
Configuration	getConf()
Database	getDatabase(java.lang.String name)
java.util.List<java.lang.String>	getDatabases(java.lang.String pattern)
java.util.List<PrivilegeGrantInfo>	getDBPrivilege(java.lang.String dbName, java.lang.String principalName, PrincipalType principalType)
PrincipalPrivilegeSet	getDBPrivilegeSet(java.lang.String dbName, java.lang.String userName, java.util.List<java.lang.String> groupNames)
Index	getIndex(java.lang.String dbName, java.lang.String origTableName, java.lang.String indexName)
java.util.List<Index>	getIndexes(java.lang.String dbName, java.lang.String origTableName, int max)
java.lang.String[]	getMasterKeys()
java.lang.String	getMetaStoreSchemaVersion()
Partition	getPartition(java.lang.String dbName, java.lang.String tableName, java.util.List<java.lang.String> part_vals)
ColumnStatistics	getPartitionColumnStatistics(java.lang.String dbName, java.lang.String tableName, java.lang.String partName, java.util.List<java.lang.String> partVal, java.lang.String colName) Returns the relevant column statistics for a given column in a given partition in a given table in a given database if such statistics exist.
PrincipalPrivilegeSet	getPartitionPrivilegeSet(java.lang.String dbName, java.lang.String tableName, java.lang.String partition, java.lang.String userName, java.util.List<java.lang.String> groupNames)
java.util.List<Partition>	getPartitions(java.lang.String dbName, java.lang.String tableName, int maxParts)
java.util.List<Partition>	getPartitionsByFilter(java.lang.String dbName, java.lang.String tblName, java.lang.String filter, short maxParts)
protected java.util.List<Partition>	getPartitionsByFilterInternal(java.lang.String dbName, java.lang.String tblName, java.lang.String filter, short maxParts, boolean allowSql, boolean allowJdo)
java.util.List<Partition>	getPartitionsByNames(java.lang.String dbName, java.lang.String tblName, java.util.List<java.lang.String> partNames)
protected java.util.List<Partition>	getPartitionsByNamesInternal(java.lang.String dbName, java.lang.String tblName, java.util.List<java.lang.String> partNames, boolean allowSql, boolean allowJdo)
protected java.util.List<Partition>	getPartitionsInternal(java.lang.String dbName, java.lang.String tableName, int maxParts, boolean allowSql, boolean allowJdo)
java.util.List<Partition>	getPartitionsWithAuth(java.lang.String dbName, java.lang.String tblName, short max, java.lang.String userName, java.util.List<java.lang.String> groupNames)
Partition	getPartitionWithAuth(java.lang.String dbName, java.lang.String tblName, java.util.List<java.lang.String> partVals, java.lang.String user_name, java.util.List<java.lang.String> group_names)
javax.jdo.PersistenceManager	getPersistenceManager()
Role	getRole(java.lang.String roleName)
Table	getTable(java.lang.String dbName, java.lang.String tableName)
ColumnStatistics	getTableColumnStatistics(java.lang.String dbName, java.lang.String tableName, java.lang.String colName) Returns the relevant column statistics for a given column in a given table in a given database if such statistics exist.
java.util.List<Table>	getTableObjectsByName(java.lang.String db, java.util.List<java.lang.String> tbl_names)
PrincipalPrivilegeSet	getTablePrivilegeSet(java.lang.String dbName, java.lang.String tableName, java.lang.String userName, java.util.List<java.lang.String> groupNames)
java.util.List<java.lang.String>	getTables(java.lang.String dbName, java.lang.String pattern)
java.lang.String	getToken(java.lang.String tokenId)
Type	getType(java.lang.String typeName)
PrincipalPrivilegeSet	getUserPrivilegeSet(java.lang.String userName, java.util.List<java.lang.String> groupNames)
boolean	grantPrivileges(PrivilegeBag privileges)
boolean	grantRole(Role role, java.lang.String userName, PrincipalType principalType, java.lang.String grantor, PrincipalType grantorType, boolean grantOption)
boolean	isActiveTransaction()
boolean	isPartitionMarkedForEvent(java.lang.String dbName, java.lang.String tblName, java.util.Map<java.lang.String,java.lang.String> partName, PartitionEventType evtType)
java.util.List<MTablePrivilege>	listAllTableGrants(java.lang.String principalName, PrincipalType principalType, java.lang.String dbName, java.lang.String tableName)
java.util.List<MTablePrivilege>	listAllTableGrants(java.lang.String dbName, java.lang.String tableName)
java.util.Set<java.lang.String>	listFSRoots() The following API - listFSRoots is used by HiveMetaTool.
java.util.List<java.lang.String>	listIndexNames(java.lang.String dbName, java.lang.String origTableName, short max)
java.util.List<MPartitionColumnPrivilege>	listPartitionAllColumnGrants(java.lang.String dbName, java.lang.String tableName, java.lang.String partName)
java.util.List<java.lang.String>	listPartitionNames(java.lang.String dbName, java.lang.String tableName, short max)
java.util.List<java.lang.String>	listPartitionNamesByFilter(java.lang.String dbName, java.lang.String tableName, java.lang.String filter, short maxParts)
java.util.List<java.lang.String>	listPartitionNamesPs(java.lang.String dbName, java.lang.String tableName, java.util.List<java.lang.String> part_vals, short max_parts) Lists partition names that match a given partial specification
java.util.List<Partition>	listPartitionsPsWithAuth(java.lang.String db_name, java.lang.String tbl_name, java.util.List<java.lang.String> part_vals, short max_parts, java.lang.String userName, java.util.List<java.lang.String> groupNames) Lists partitions that match a given partial specification and sets their auth privileges.
java.util.List<MDBPrivilege>	listPrincipalDBGrants(java.lang.String principalName, PrincipalType principalType, java.lang.String dbName)
java.util.List<MGlobalPrivilege>	listPrincipalGlobalGrants(java.lang.String principalName, PrincipalType principalType)
java.util.List<MPartitionColumnPrivilege>	listPrincipalPartitionColumnGrants(java.lang.String principalName, PrincipalType principalType, java.lang.String dbName, java.lang.String tableName, java.lang.String partitionName, java.lang.String columnName)
java.util.List<MPartitionPrivilege>	listPrincipalPartitionGrants(java.lang.String principalName, PrincipalType principalType, java.lang.String dbName, java.lang.String tableName, java.lang.String partName)
java.util.List<MTableColumnPrivilege>	listPrincipalTableColumnGrants(java.lang.String principalName, PrincipalType principalType, java.lang.String dbName, java.lang.String tableName, java.lang.String columnName)
java.util.List<java.lang.String>	listRoleNames()
java.util.List<MRoleMap>	listRoles(java.lang.String principalName, PrincipalType principalType)
java.util.List<MTableColumnPrivilege>	listTableAllColumnGrants(java.lang.String dbName, java.lang.String tableName)
java.util.List<MPartitionColumnPrivilege>	listTableAllPartitionColumnGrants(java.lang.String dbName, java.lang.String tableName)
java.util.List<MPartitionPrivilege>	listTableAllPartitionGrants(java.lang.String dbName, java.lang.String tableName)
java.util.List<java.lang.String>	listTableNamesByFilter(java.lang.String dbName, java.lang.String filter, short maxTables) Gets a list of tables based on a filter string and filter type.
Table	markPartitionForEvent(java.lang.String dbName, java.lang.String tblName, java.util.Map<java.lang.String,java.lang.String> partName, PartitionEventType evtType)
boolean	openTransaction() Opens a new one or the one already created Every call of this function must have corresponding commit or rollback function call
boolean	removeMasterKey(java.lang.Integer id)
boolean	removeRole(java.lang.String roleName)
boolean	removeToken(java.lang.String tokenId)
boolean	revokePrivileges(PrivilegeBag privileges)
boolean	revokeRole(Role role, java.lang.String userName, PrincipalType principalType)
void	rollbackTransaction() Rolls back the current transaction if it is active
void	setConf(Configuration conf) Called whenever this object is instantiated using ReflectionUils, and also on connection retries.
void	setMetaStoreSchemaVersion(java.lang.String schemaVersion, java.lang.String comment)
void	shutdown()
void	updateMasterKey(java.lang.Integer id, java.lang.String key)
ObjectStore.UpdateMDatabaseURIRetVal	updateMDatabaseURI(java.net.URI oldLoc, java.net.URI newLoc, boolean dryRun) The following APIs - updateMDatabaseURI is used by HiveMetaTool.
ObjectStore.UpdateMStorageDescriptorTblPropURIRetVal	updateMStorageDescriptorTblPropURI(java.net.URI oldLoc, java.net.URI newLoc, java.lang.String tblPropKey, boolean isDryRun) The following APIs - updateMStorageDescriptorTblPropURI is used by HiveMetaTool.
ObjectStore.UpdateMStorageDescriptorTblURIRetVal	updateMStorageDescriptorTblURI(java.net.URI oldLoc, java.net.URI newLoc, boolean isDryRun) The following APIs - updateMStorageDescriptorTblURI is used by HiveMetaTool.
boolean	updatePartitionColumnStatistics(ColumnStatistics colStats, java.util.List<java.lang.String> partVals) Persists the given column statistics object to the metastore
ObjectStore.UpdateSerdeURIRetVal	updateSerdeURI(java.net.URI oldLoc, java.net.URI newLoc, java.lang.String serdeProp, boolean isDryRun) The following APIs - updateSerdeURI is used by HiveMetaTool.
boolean	updateTableColumnStatistics(ColumnStatistics colStats) Persists the given column statistics object to the metastore
void	verifySchema()

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectStore

public ObjectStore()

Method Detail

getConf

public Configuration getConf()

setConf

public void setConf(Configuration conf)

Called whenever this object is instantiated using ReflectionUils, and also on connection retries. In cases of connection retries, conf will usually contain modified values.

getPersistenceManager

@InterfaceAudience.LimitedPrivate(value="HCATALOG")
 @InterfaceStability.Evolving
public javax.jdo.PersistenceManager getPersistenceManager()

shutdown

public void shutdown()

Specified by:

shutdown in interface RawStore

openTransaction

public boolean openTransaction()

Opens a new one or the one already created Every call of this function must have corresponding commit or rollback function call

Specified by:

openTransaction in interface RawStore

Returns:

an active transaction

commitTransaction

public boolean commitTransaction()

if this is the commit of the first open call then an actual commit is called.

Specified by:

commitTransaction in interface RawStore

Returns:

Always returns true

isActiveTransaction

public boolean isActiveTransaction()

Returns:

true if there is an active transaction. If the current transaction is either committed or rolled back it returns false

rollbackTransaction

public void rollbackTransaction()

Rolls back the current transaction if it is active

Specified by:

rollbackTransaction in interface RawStore

createDatabase

public void createDatabase(Database db)
                    throws InvalidObjectException,
                           MetaException

Specified by:

createDatabase in interface RawStore

Throws:

InvalidObjectException

MetaException

getDatabase

public Database getDatabase(java.lang.String name)
                     throws NoSuchObjectException

Specified by:

getDatabase in interface RawStore

Throws:

NoSuchObjectException

alterDatabase

public boolean alterDatabase(java.lang.String dbName,
                             Database db)
                      throws MetaException,
                             NoSuchObjectException

Alter the database object in metastore. Currently only the parameters of the database can be changed.

Specified by:

alterDatabase in interface RawStore

Parameters:

dbName - the database name

db - the Hive Database object

Throws:

MetaException

NoSuchObjectException

dropDatabase

public boolean dropDatabase(java.lang.String dbname)
                     throws NoSuchObjectException,
                            MetaException

Specified by:

dropDatabase in interface RawStore

Throws:

NoSuchObjectException

MetaException

getDatabases

public java.util.List<java.lang.String> getDatabases(java.lang.String pattern)
                                              throws MetaException

Specified by:

getDatabases in interface RawStore

Throws:

MetaException

getAllDatabases

public java.util.List<java.lang.String> getAllDatabases()
                                                 throws MetaException

Specified by:

getAllDatabases in interface RawStore

Throws:

MetaException

createType

public boolean createType(Type type)

Specified by:

createType in interface RawStore

getType

public Type getType(java.lang.String typeName)

Specified by:

getType in interface RawStore

dropType

public boolean dropType(java.lang.String typeName)

Specified by:

dropType in interface RawStore

createTable

public void createTable(Table tbl)
                 throws InvalidObjectException,
                        MetaException

Specified by:

createTable in interface RawStore

Throws:

InvalidObjectException

MetaException

dropTable

public boolean dropTable(java.lang.String dbName,
                         java.lang.String tableName)
                  throws MetaException,
                         NoSuchObjectException,
                         InvalidObjectException,
                         InvalidInputException

Specified by:

dropTable in interface RawStore

Throws:

MetaException

NoSuchObjectException

InvalidObjectException

InvalidInputException

getTable

public Table getTable(java.lang.String dbName,
                      java.lang.String tableName)
               throws MetaException

Specified by:

getTable in interface RawStore

Throws:

MetaException

getTables

public java.util.List<java.lang.String> getTables(java.lang.String dbName,
                                                  java.lang.String pattern)
                                           throws MetaException

Specified by:

getTables in interface RawStore

Throws:

MetaException

getAllTables

public java.util.List<java.lang.String> getAllTables(java.lang.String dbName)
                                              throws MetaException

Specified by:

getAllTables in interface RawStore

Throws:

MetaException

getTableObjectsByName

public java.util.List<Table> getTableObjectsByName(java.lang.String db,
                                                   java.util.List<java.lang.String> tbl_names)
                                            throws MetaException,
                                                   UnknownDBException

Specified by:

getTableObjectsByName in interface RawStore

Parameters:

db - The name of the database from which to retrieve the tables

tbl_names - The names of the tables to retrieve.

Returns:

A list of the tables retrievable from the database whose names are in the list tableNames. If there are duplicate names, only one instance of the table will be returned

Throws:

MetaException

UnknownDBException

addPartition

public boolean addPartition(Partition part)
                     throws InvalidObjectException,
                            MetaException

Specified by:

addPartition in interface RawStore

Throws:

InvalidObjectException

MetaException

getPartition

public Partition getPartition(java.lang.String dbName,
                              java.lang.String tableName,
                              java.util.List<java.lang.String> part_vals)
                       throws NoSuchObjectException,
                              MetaException

Specified by:

getPartition in interface RawStore

Throws:

NoSuchObjectException

MetaException

dropPartition

public boolean dropPartition(java.lang.String dbName,
                             java.lang.String tableName,
                             java.util.List<java.lang.String> part_vals)
                      throws MetaException,
                             NoSuchObjectException,
                             InvalidObjectException,
                             InvalidInputException

Specified by:

dropPartition in interface RawStore

Throws:

MetaException

NoSuchObjectException

InvalidObjectException

InvalidInputException

getPartitions

public java.util.List<Partition> getPartitions(java.lang.String dbName,
                                               java.lang.String tableName,
                                               int maxParts)
                                        throws MetaException

Specified by:

getPartitions in interface RawStore

Throws:

MetaException

getPartitionsInternal

protected java.util.List<Partition> getPartitionsInternal(java.lang.String dbName,
                                                          java.lang.String tableName,
                                                          int maxParts,
                                                          boolean allowSql,
                                                          boolean allowJdo)
                                                   throws MetaException

Throws:

MetaException

getPartitionsWithAuth

public java.util.List<Partition> getPartitionsWithAuth(java.lang.String dbName,
                                                       java.lang.String tblName,
                                                       short max,
                                                       java.lang.String userName,
                                                       java.util.List<java.lang.String> groupNames)
                                                throws MetaException,
                                                       NoSuchObjectException,
                                                       InvalidObjectException

Specified by:

getPartitionsWithAuth in interface RawStore

Throws:

MetaException

NoSuchObjectException

InvalidObjectException

getPartitionWithAuth

public Partition getPartitionWithAuth(java.lang.String dbName,
                                      java.lang.String tblName,
                                      java.util.List<java.lang.String> partVals,
                                      java.lang.String user_name,
                                      java.util.List<java.lang.String> group_names)
                               throws NoSuchObjectException,
                                      MetaException,
                                      InvalidObjectException

Specified by:

getPartitionWithAuth in interface RawStore

Throws:

NoSuchObjectException

MetaException

InvalidObjectException

listPartitionNames

public java.util.List<java.lang.String> listPartitionNames(java.lang.String dbName,
                                                           java.lang.String tableName,
                                                           short max)
                                                    throws MetaException

Specified by:

listPartitionNames in interface RawStore

Throws:

MetaException

listPartitionsPsWithAuth

public java.util.List<Partition> listPartitionsPsWithAuth(java.lang.String db_name,
                                                          java.lang.String tbl_name,
                                                          java.util.List<java.lang.String> part_vals,
                                                          short max_parts,
                                                          java.lang.String userName,
                                                          java.util.List<java.lang.String> groupNames)
                                                   throws MetaException,
                                                          InvalidObjectException,
                                                          NoSuchObjectException

Description copied from interface: RawStore

Lists partitions that match a given partial specification and sets their auth privileges. If userName and groupNames null, then no auth privileges are set.

Specified by:

listPartitionsPsWithAuth in interface RawStore

Parameters:

db_name - The name of the database which has the partitions

tbl_name - The name of the table which has the partitions

part_vals - A partial list of values for partitions in order of the table's partition keys Entries can be empty if you need to specify latter partitions.

max_parts - The maximum number of partitions to return

userName - The user name for the partition for authentication privileges

groupNames - The groupNames for the partition for authentication privileges

Returns:

A list of partitions that match the partial spec.

Throws:

MetaException

InvalidObjectException

NoSuchObjectException

listPartitionNamesPs

public java.util.List<java.lang.String> listPartitionNamesPs(java.lang.String dbName,
                                                             java.lang.String tableName,
                                                             java.util.List<java.lang.String> part_vals,
                                                             short max_parts)
                                                      throws MetaException,
                                                             NoSuchObjectException

Description copied from interface: RawStore

Lists partition names that match a given partial specification

Specified by:

listPartitionNamesPs in interface RawStore

Parameters:

dbName - The name of the database which has the partitions

tableName - The name of the table which has the partitions

part_vals - A partial list of values for partitions in order of the table's partition keys. Entries can be empty if you only want to specify latter partitions.

max_parts - The maximum number of partitions to return

Returns:

A list of partition names that match the partial spec.

Throws:

MetaException

NoSuchObjectException

getPartitionsByNames

public java.util.List<Partition> getPartitionsByNames(java.lang.String dbName,
                                                      java.lang.String tblName,
                                                      java.util.List<java.lang.String> partNames)
                                               throws MetaException,
                                                      NoSuchObjectException

Specified by:

getPartitionsByNames in interface RawStore

Throws:

MetaException

NoSuchObjectException

getPartitionsByNamesInternal

protected java.util.List<Partition> getPartitionsByNamesInternal(java.lang.String dbName,
                                                                 java.lang.String tblName,
                                                                 java.util.List<java.lang.String> partNames,
                                                                 boolean allowSql,
                                                                 boolean allowJdo)
                                                          throws MetaException,
                                                                 NoSuchObjectException

Throws:

MetaException

NoSuchObjectException

getPartitionsByFilter

public java.util.List<Partition> getPartitionsByFilter(java.lang.String dbName,
                                                       java.lang.String tblName,
                                                       java.lang.String filter,
                                                       short maxParts)
                                                throws MetaException,
                                                       NoSuchObjectException

Specified by:

getPartitionsByFilter in interface RawStore

Throws:

MetaException

NoSuchObjectException

getPartitionsByFilterInternal

protected java.util.List<Partition> getPartitionsByFilterInternal(java.lang.String dbName,
                                                                  java.lang.String tblName,
                                                                  java.lang.String filter,
                                                                  short maxParts,
                                                                  boolean allowSql,
                                                                  boolean allowJdo)
                                                           throws MetaException,
                                                                  NoSuchObjectException

Throws:

MetaException

NoSuchObjectException

listTableNamesByFilter

public java.util.List<java.lang.String> listTableNamesByFilter(java.lang.String dbName,
                                                               java.lang.String filter,
                                                               short maxTables)
                                                        throws MetaException

Description copied from interface: RawStore

Gets a list of tables based on a filter string and filter type.

Specified by:

listTableNamesByFilter in interface RawStore

Parameters:

dbName - The name of the database from which you will retrieve the table names

filter - The filter string

maxTables - The maximum number of tables returned

Returns:

A list of table names that match the desired filter

Throws:

MetaException

listPartitionNamesByFilter

public java.util.List<java.lang.String> listPartitionNamesByFilter(java.lang.String dbName,
                                                                   java.lang.String tableName,
                                                                   java.lang.String filter,
                                                                   short maxParts)
                                                            throws MetaException

Specified by:

listPartitionNamesByFilter in interface RawStore

Throws:

MetaException

alterTable

public void alterTable(java.lang.String dbname,
                       java.lang.String name,
                       Table newTable)
                throws InvalidObjectException,
                       MetaException

Specified by:

alterTable in interface RawStore

Throws:

InvalidObjectException

MetaException

alterIndex

public void alterIndex(java.lang.String dbname,
                       java.lang.String baseTblName,
                       java.lang.String name,
                       Index newIndex)
                throws InvalidObjectException,
                       MetaException

Specified by:

alterIndex in interface RawStore

Throws:

InvalidObjectException

MetaException

alterPartition

public void alterPartition(java.lang.String dbname,
                           java.lang.String name,
                           java.util.List<java.lang.String> part_vals,
                           Partition newPart)
                    throws InvalidObjectException,
                           MetaException

Specified by:

alterPartition in interface RawStore

Throws:

InvalidObjectException

MetaException

alterPartitions

public void alterPartitions(java.lang.String dbname,
                            java.lang.String name,
                            java.util.List<java.util.List<java.lang.String>> part_vals,
                            java.util.List<Partition> newParts)
                     throws InvalidObjectException,
                            MetaException

Specified by:

alterPartitions in interface RawStore

Throws:

InvalidObjectException

MetaException

addIndex

public boolean addIndex(Index index)
                 throws InvalidObjectException,
                        MetaException

Specified by:

addIndex in interface RawStore

Throws:

InvalidObjectException

MetaException

dropIndex

public boolean dropIndex(java.lang.String dbName,
                         java.lang.String origTableName,
                         java.lang.String indexName)
                  throws MetaException

Specified by:

dropIndex in interface RawStore

Throws:

MetaException

getIndex

public Index getIndex(java.lang.String dbName,
                      java.lang.String origTableName,
                      java.lang.String indexName)
               throws MetaException

Specified by:

getIndex in interface RawStore

Throws:

MetaException

getIndexes

public java.util.List<Index> getIndexes(java.lang.String dbName,
                                        java.lang.String origTableName,
                                        int max)
                                 throws MetaException

Specified by:

getIndexes in interface RawStore

Throws:

MetaException

listIndexNames

public java.util.List<java.lang.String> listIndexNames(java.lang.String dbName,
                                                       java.lang.String origTableName,
                                                       short max)
                                                throws MetaException

Specified by:

listIndexNames in interface RawStore

Throws:

MetaException

addRole

public boolean addRole(java.lang.String roleName,
                       java.lang.String ownerName)
                throws InvalidObjectException,
                       MetaException,
                       NoSuchObjectException

Specified by:

addRole in interface RawStore

Throws:

InvalidObjectException

MetaException

NoSuchObjectException

grantRole

public boolean grantRole(Role role,
                         java.lang.String userName,
                         PrincipalType principalType,
                         java.lang.String grantor,
                         PrincipalType grantorType,
                         boolean grantOption)
                  throws MetaException,
                         NoSuchObjectException,
                         InvalidObjectException

Specified by:

grantRole in interface RawStore

Throws:

MetaException

NoSuchObjectException

InvalidObjectException

revokeRole

public boolean revokeRole(Role role,
                          java.lang.String userName,
                          PrincipalType principalType)
                   throws MetaException,
                          NoSuchObjectException

Specified by:

revokeRole in interface RawStore

Throws:

MetaException

NoSuchObjectException

removeRole

public boolean removeRole(java.lang.String roleName)
                   throws MetaException,
                          NoSuchObjectException

Specified by:

removeRole in interface RawStore

Throws:

MetaException

NoSuchObjectException

listRoles

public java.util.List<MRoleMap> listRoles(java.lang.String principalName,
                                          PrincipalType principalType)

Specified by:

listRoles in interface RawStore

getRole

public Role getRole(java.lang.String roleName)
             throws NoSuchObjectException

Specified by:

getRole in interface RawStore

Throws:

NoSuchObjectException

listRoleNames

public java.util.List<java.lang.String> listRoleNames()

Specified by:

listRoleNames in interface RawStore

getUserPrivilegeSet

public PrincipalPrivilegeSet getUserPrivilegeSet(java.lang.String userName,
                                                 java.util.List<java.lang.String> groupNames)
                                          throws InvalidObjectException,
                                                 MetaException

Specified by:

getUserPrivilegeSet in interface RawStore

Throws:

InvalidObjectException

MetaException

getDBPrivilege

public java.util.List<PrivilegeGrantInfo> getDBPrivilege(java.lang.String dbName,
                                                         java.lang.String principalName,
                                                         PrincipalType principalType)
                                                  throws InvalidObjectException,
                                                         MetaException

Throws:

InvalidObjectException

MetaException

getDBPrivilegeSet

public PrincipalPrivilegeSet getDBPrivilegeSet(java.lang.String dbName,
                                               java.lang.String userName,
                                               java.util.List<java.lang.String> groupNames)
                                        throws InvalidObjectException,
                                               MetaException

Specified by:

getDBPrivilegeSet in interface RawStore

Throws:

InvalidObjectException

MetaException

getPartitionPrivilegeSet

public PrincipalPrivilegeSet getPartitionPrivilegeSet(java.lang.String dbName,
                                                      java.lang.String tableName,
                                                      java.lang.String partition,
                                                      java.lang.String userName,
                                                      java.util.List<java.lang.String> groupNames)
                                               throws InvalidObjectException,
                                                      MetaException

Specified by:

getPartitionPrivilegeSet in interface RawStore

Throws:

InvalidObjectException

MetaException

getTablePrivilegeSet

public PrincipalPrivilegeSet getTablePrivilegeSet(java.lang.String dbName,
                                                  java.lang.String tableName,
                                                  java.lang.String userName,
                                                  java.util.List<java.lang.String> groupNames)
                                           throws InvalidObjectException,
                                                  MetaException

Specified by:

getTablePrivilegeSet in interface RawStore

Throws:

InvalidObjectException

MetaException

getColumnPrivilegeSet

public PrincipalPrivilegeSet getColumnPrivilegeSet(java.lang.String dbName,
                                                   java.lang.String tableName,
                                                   java.lang.String partitionName,
                                                   java.lang.String columnName,
                                                   java.lang.String userName,
                                                   java.util.List<java.lang.String> groupNames)
                                            throws InvalidObjectException,
                                                   MetaException

Specified by:

getColumnPrivilegeSet in interface RawStore

Throws:

InvalidObjectException

MetaException

grantPrivileges

public boolean grantPrivileges(PrivilegeBag privileges)
                        throws InvalidObjectException,
                               MetaException,
                               NoSuchObjectException

Specified by:

grantPrivileges in interface RawStore

Throws:

InvalidObjectException

MetaException

NoSuchObjectException

revokePrivileges

public boolean revokePrivileges(PrivilegeBag privileges)
                         throws InvalidObjectException,
                                MetaException,
                                NoSuchObjectException

Specified by:

revokePrivileges in interface RawStore

Throws:

InvalidObjectException

MetaException

NoSuchObjectException

listPrincipalGlobalGrants

public java.util.List<MGlobalPrivilege> listPrincipalGlobalGrants(java.lang.String principalName,
                                                                  PrincipalType principalType)

Specified by:

listPrincipalGlobalGrants in interface RawStore

listPrincipalDBGrants

public java.util.List<MDBPrivilege> listPrincipalDBGrants(java.lang.String principalName,
                                                          PrincipalType principalType,
                                                          java.lang.String dbName)

Specified by:

listPrincipalDBGrants in interface RawStore

listAllTableGrants

public java.util.List<MTablePrivilege> listAllTableGrants(java.lang.String dbName,
                                                          java.lang.String tableName)

listTableAllPartitionGrants

public java.util.List<MPartitionPrivilege> listTableAllPartitionGrants(java.lang.String dbName,
                                                                       java.lang.String tableName)

listTableAllColumnGrants

public java.util.List<MTableColumnPrivilege> listTableAllColumnGrants(java.lang.String dbName,
                                                                      java.lang.String tableName)

listTableAllPartitionColumnGrants

public java.util.List<MPartitionColumnPrivilege> listTableAllPartitionColumnGrants(java.lang.String dbName,
                                                                                   java.lang.String tableName)

listPartitionAllColumnGrants

public java.util.List<MPartitionColumnPrivilege> listPartitionAllColumnGrants(java.lang.String dbName,
                                                                              java.lang.String tableName,
                                                                              java.lang.String partName)

listAllTableGrants

public java.util.List<MTablePrivilege> listAllTableGrants(java.lang.String principalName,
                                                          PrincipalType principalType,
                                                          java.lang.String dbName,
                                                          java.lang.String tableName)

Specified by:

listAllTableGrants in interface RawStore

listPrincipalPartitionGrants

public java.util.List<MPartitionPrivilege> listPrincipalPartitionGrants(java.lang.String principalName,
                                                                        PrincipalType principalType,
                                                                        java.lang.String dbName,
                                                                        java.lang.String tableName,
                                                                        java.lang.String partName)

Specified by:

listPrincipalPartitionGrants in interface RawStore

listPrincipalTableColumnGrants

public java.util.List<MTableColumnPrivilege> listPrincipalTableColumnGrants(java.lang.String principalName,
                                                                            PrincipalType principalType,
                                                                            java.lang.String dbName,
                                                                            java.lang.String tableName,
                                                                            java.lang.String columnName)

Specified by:

listPrincipalTableColumnGrants in interface RawStore

listPrincipalPartitionColumnGrants

public java.util.List<MPartitionColumnPrivilege> listPrincipalPartitionColumnGrants(java.lang.String principalName,
                                                                                    PrincipalType principalType,
                                                                                    java.lang.String dbName,
                                                                                    java.lang.String tableName,
                                                                                    java.lang.String partitionName,
                                                                                    java.lang.String columnName)

Specified by:

listPrincipalPartitionColumnGrants in interface RawStore

isPartitionMarkedForEvent

public boolean isPartitionMarkedForEvent(java.lang.String dbName,
                                         java.lang.String tblName,
                                         java.util.Map<java.lang.String,java.lang.String> partName,
                                         PartitionEventType evtType)
                                  throws UnknownTableException,
                                         MetaException,
                                         InvalidPartitionException,
                                         UnknownPartitionException

Specified by:

isPartitionMarkedForEvent in interface RawStore

Throws:

UnknownTableException

MetaException

InvalidPartitionException

UnknownPartitionException

markPartitionForEvent

public Table markPartitionForEvent(java.lang.String dbName,
                                   java.lang.String tblName,
                                   java.util.Map<java.lang.String,java.lang.String> partName,
                                   PartitionEventType evtType)
                            throws MetaException,
                                   UnknownTableException,
                                   InvalidPartitionException,
                                   UnknownPartitionException

Specified by:

markPartitionForEvent in interface RawStore

Throws:

MetaException

UnknownTableException

InvalidPartitionException

UnknownPartitionException

executeJDOQLSelect

public java.util.Collection<?> executeJDOQLSelect(java.lang.String query)

The following API - executeJDOQLSelect is used by HiveMetaTool. This API **shouldn't** be exposed via Thrift.

executeJDOQLUpdate

public long executeJDOQLUpdate(java.lang.String query)

The following API - executeJDOQLUpdate is used by HiveMetaTool. This API **shouldn't** be exposed via Thrift.

listFSRoots

public java.util.Set<java.lang.String> listFSRoots()

The following API - listFSRoots is used by HiveMetaTool. This API **shouldn't** be exposed via Thrift.

updateMDatabaseURI

public ObjectStore.UpdateMDatabaseURIRetVal updateMDatabaseURI(java.net.URI oldLoc,
                                                               java.net.URI newLoc,
                                                               boolean dryRun)

The following APIs - updateMDatabaseURI is used by HiveMetaTool. This API **shouldn't** be exposed via Thrift.

updateMStorageDescriptorTblPropURI

public ObjectStore.UpdateMStorageDescriptorTblPropURIRetVal updateMStorageDescriptorTblPropURI(java.net.URI oldLoc,
                                                                                               java.net.URI newLoc,
                                                                                               java.lang.String tblPropKey,
                                                                                               boolean isDryRun)

The following APIs - updateMStorageDescriptorTblPropURI is used by HiveMetaTool. This API **shouldn't** be exposed via Thrift.

updateMStorageDescriptorTblURI

public ObjectStore.UpdateMStorageDescriptorTblURIRetVal updateMStorageDescriptorTblURI(java.net.URI oldLoc,
                                                                                       java.net.URI newLoc,
                                                                                       boolean isDryRun)

The following APIs - updateMStorageDescriptorTblURI is used by HiveMetaTool. This API **shouldn't** be exposed via Thrift.

updateSerdeURI

public ObjectStore.UpdateSerdeURIRetVal updateSerdeURI(java.net.URI oldLoc,
                                                       java.net.URI newLoc,
                                                       java.lang.String serdeProp,
                                                       boolean isDryRun)

The following APIs - updateSerdeURI is used by HiveMetaTool. This API **shouldn't** be exposed via Thrift.

updateTableColumnStatistics

public boolean updateTableColumnStatistics(ColumnStatistics colStats)
                                    throws NoSuchObjectException,
                                           MetaException,
                                           InvalidObjectException,
                                           InvalidInputException

Description copied from interface: RawStore

Persists the given column statistics object to the metastore

Specified by:

updateTableColumnStatistics in interface RawStore

Returns:

Boolean indicating the outcome of the operation

Throws:

NoSuchObjectException

MetaException

InvalidObjectException

InvalidInputException

updatePartitionColumnStatistics

public boolean updatePartitionColumnStatistics(ColumnStatistics colStats,
                                               java.util.List<java.lang.String> partVals)
                                        throws NoSuchObjectException,
                                               MetaException,
                                               InvalidObjectException,
                                               InvalidInputException

Description copied from interface: RawStore

Persists the given column statistics object to the metastore

Specified by:

updatePartitionColumnStatistics in interface RawStore

Returns:

Boolean indicating the outcome of the operation

Throws:

NoSuchObjectException

MetaException

InvalidObjectException

InvalidInputException

getTableColumnStatistics

public ColumnStatistics getTableColumnStatistics(java.lang.String dbName,
                                                 java.lang.String tableName,
                                                 java.lang.String colName)
                                          throws MetaException,
                                                 NoSuchObjectException,
                                                 InvalidInputException

Description copied from interface: RawStore

Returns the relevant column statistics for a given column in a given table in a given database if such statistics exist.

Specified by:

getTableColumnStatistics in interface RawStore

Returns:

Relevant column statistics for the column for the given table

Throws:

MetaException

NoSuchObjectException

InvalidInputException

getPartitionColumnStatistics

public ColumnStatistics getPartitionColumnStatistics(java.lang.String dbName,
                                                     java.lang.String tableName,
                                                     java.lang.String partName,
                                                     java.util.List<java.lang.String> partVal,
                                                     java.lang.String colName)
                                              throws MetaException,
                                                     NoSuchObjectException,
                                                     InvalidInputException

Description copied from interface: RawStore

Returns the relevant column statistics for a given column in a given partition in a given table in a given database if such statistics exist.

Specified by:

getPartitionColumnStatistics in interface RawStore

Returns:

Relevant column statistics for the column for the given partition in a given table

Throws:

MetaException

NoSuchObjectException

InvalidInputException

deletePartitionColumnStatistics

public boolean deletePartitionColumnStatistics(java.lang.String dbName,
                                               java.lang.String tableName,
                                               java.lang.String partName,
                                               java.util.List<java.lang.String> partVals,
                                               java.lang.String colName)
                                        throws NoSuchObjectException,
                                               MetaException,
                                               InvalidObjectException,
                                               InvalidInputException

Description copied from interface: RawStore

Deletes column statistics if present associated with a given db, table, partition and col. If null is passed instead of a colName, stats when present for all columns associated with a given db, table and partition are deleted.

Specified by:

deletePartitionColumnStatistics in interface RawStore

Returns:

Boolean indicating the outcome of the operation

Throws:

NoSuchObjectException

MetaException

InvalidObjectException

InvalidInputException

deleteTableColumnStatistics

public boolean deleteTableColumnStatistics(java.lang.String dbName,
                                           java.lang.String tableName,
                                           java.lang.String colName)
                                    throws NoSuchObjectException,
                                           MetaException,
                                           InvalidObjectException,
                                           InvalidInputException

Description copied from interface: RawStore

Deletes column statistics if present associated with a given db, table and col. If null is passed instead of a colName, stats when present for all columns associated with a given db and table are deleted.

Specified by:

deleteTableColumnStatistics in interface RawStore

Returns:

Boolean indicating the outcome of the operation

Throws:

NoSuchObjectException

MetaException

InvalidObjectException

InvalidInputException

cleanupEvents

public long cleanupEvents()

Specified by:

cleanupEvents in interface RawStore

addToken

public boolean addToken(java.lang.String tokenId,
                        java.lang.String delegationToken)

Specified by:

addToken in interface RawStore

removeToken

public boolean removeToken(java.lang.String tokenId)

Specified by:

removeToken in interface RawStore

getToken

public java.lang.String getToken(java.lang.String tokenId)

Specified by:

getToken in interface RawStore

getAllTokenIdentifiers

public java.util.List<java.lang.String> getAllTokenIdentifiers()

Specified by:

getAllTokenIdentifiers in interface RawStore

addMasterKey

public int addMasterKey(java.lang.String key)
                 throws MetaException

Specified by:

addMasterKey in interface RawStore

Throws:

MetaException

updateMasterKey

public void updateMasterKey(java.lang.Integer id,
                            java.lang.String key)
                     throws NoSuchObjectException,
                            MetaException

Specified by:

updateMasterKey in interface RawStore

Throws:

NoSuchObjectException

MetaException

removeMasterKey

public boolean removeMasterKey(java.lang.Integer id)

Specified by:

removeMasterKey in interface RawStore

getMasterKeys

public java.lang.String[] getMasterKeys()

Specified by:

getMasterKeys in interface RawStore

verifySchema

public void verifySchema()
                  throws MetaException

Specified by:

verifySchema in interface RawStore

Throws:

MetaException

getMetaStoreSchemaVersion

public java.lang.String getMetaStoreSchemaVersion()
                                           throws MetaException

Specified by:

getMetaStoreSchemaVersion in interface RawStore

Throws:

MetaException

setMetaStoreSchemaVersion

public void setMetaStoreSchemaVersion(java.lang.String schemaVersion,
                                      java.lang.String comment)
                               throws MetaException

Specified by:

setMetaStoreSchemaVersion in interface RawStore

Throws:

MetaException