ObjectStore (Hive 1.2.2 API)

java.lang.Object
- org.apache.hadoop.hive.metastore.ObjectStore

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, RawStore
```
public class ObjectStore
extends Object
implements RawStore, org.apache.hadoop.conf.Configurable
```
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.UpdateMStorageDescriptorTblURIRetVal`
`class`	`ObjectStore.UpdatePropURIRetVal`
`class`	`ObjectStore.UpdateSerdeURIRetVal`

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

Constructor Summary

Constructors
Constructor and Description

ObjectStore()

Constructors
Constructor and Description
`ObjectStore()`

Method Summary

Methods
Modifier and Type	Method and Description
`boolean`	`addIndex(Index index)`
`int`	`addMasterKey(String key)`
`void`	`addNotificationEvent(NotificationEvent entry)` Add a notification entry.
`boolean`	`addPartition(Partition part)`
`boolean`	`addPartitions(String dbName, String tblName, List<Partition> parts)`
`boolean`	`addPartitions(String dbName, String tblName, PartitionSpecProxy partitionSpec, boolean ifNotExists)`
`boolean`	`addRole(String roleName, String ownerName)`
`boolean`	`addToken(String tokenId, String delegationToken)`
`boolean`	`alterDatabase(String dbName, Database db)` Alter the database object in metastore.
`void`	`alterFunction(String dbName, String funcName, Function newFunction)` Alter function based on new function specs.
`void`	`alterIndex(String dbname, String baseTblName, String name, Index newIndex)`
`void`	`alterPartition(String dbname, String name, List<String> part_vals, Partition newPart)`
`void`	`alterPartitions(String dbname, String name, List<List<String>> part_vals, List<Partition> newParts)`
`void`	`alterTable(String dbname, String name, Table newTable)`
`void`	`cleanNotificationEvents(int olderThan)` Remove older notification events.
`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`	`createFunction(Function func)` Register a user-defined function based on the function specification passed in.
`void`	`createTable(Table tbl)`
`boolean`	`createType(Type type)`
`boolean`	`deletePartitionColumnStatistics(String dbName, String tableName, String partName, List<String> partVals, String colName)` Deletes column statistics if present associated with a given db, table, partition and col.
`boolean`	`deleteTableColumnStatistics(String dbName, String tableName, String colName)` Deletes column statistics if present associated with a given db, table and col.
`boolean`	`doesPartitionExist(String dbName, String tableName, List<String> partVals)`
`boolean`	`dropDatabase(String dbname)`
`void`	`dropFunction(String dbName, String funcName)` Drop a function definition.
`boolean`	`dropIndex(String dbName, String origTableName, String indexName)`
`boolean`	`dropPartition(String dbName, String tableName, List<String> part_vals)`
`void`	`dropPartitionAllColumnGrantsNoTxn(String dbName, String tableName, List<String> partNames)`
`void`	`dropPartitions(String dbName, String tblName, List<String> partNames)`
`boolean`	`dropTable(String dbName, String tableName)`
`boolean`	`dropType(String typeName)`
`Collection<?>`	`executeJDOQLSelect(String query)` The following API - executeJDOQLSelect is used by HiveMetaTool.
`long`	`executeJDOQLUpdate(String query)` The following API - executeJDOQLUpdate is used by HiveMetaTool.
`AggrStats`	`get_aggr_stats_for(String dbName, String tblName, List<String> partNames, List<String> colNames)`
`List<String>`	`getAllDatabases()`
`List<String>`	`getAllTables(String dbName)`
`List<String>`	`getAllTokenIdentifiers()`
`PrincipalPrivilegeSet`	`getColumnPrivilegeSet(String dbName, String tableName, String partitionName, String columnName, String userName, List<String> groupNames)`
`org.apache.hadoop.conf.Configuration`	`getConf()`
`CurrentNotificationEventId`	`getCurrentNotificationEventId()` Get the last issued notification event id.
`Database`	`getDatabase(String name)`
`Database`	`getDatabaseInternal(String name)`
`List<String>`	`getDatabases(String pattern)`
`List<PrivilegeGrantInfo>`	`getDBPrivilege(String dbName, String principalName, PrincipalType principalType)`
`PrincipalPrivilegeSet`	`getDBPrivilegeSet(String dbName, String userName, List<String> groupNames)`
`Function`	`getFunction(String dbName, String funcName)` Retrieve function by name.
`List<String>`	`getFunctions(String dbName, String pattern)` Retrieve list of function names based on name pattern.
`Index`	`getIndex(String dbName, String origTableName, String indexName)`
`List<Index>`	`getIndexes(String dbName, String origTableName, int max)`
`Database`	`getJDODatabase(String name)`
`String[]`	`getMasterKeys()`
`String`	`getMetaStoreSchemaVersion()`
`NotificationEventResponse`	`getNextNotification(NotificationEventRequest rqst)` Get the next notification event.
`Partition`	`getPartition(String dbName, String tableName, List<String> part_vals)`
`List<ColumnStatistics>`	`getPartitionColumnStatistics(String dbName, String tableName, List<String> partNames, List<String> colNames)` Returns the relevant column statistics for given columns in given partitions in a given table in a given database if such statistics exist.
`protected List<ColumnStatistics>`	`getPartitionColumnStatisticsInternal(String dbName, String tableName, List<String> partNames, List<String> colNames, boolean allowSql, boolean allowJdo)`
`PrincipalPrivilegeSet`	`getPartitionPrivilegeSet(String dbName, String tableName, String partition, String userName, List<String> groupNames)`
`List<Partition>`	`getPartitions(String dbName, String tableName, int maxParts)`
`boolean`	`getPartitionsByExpr(String dbName, String tblName, byte[] expr, String defaultPartitionName, short maxParts, List<Partition> result)`
`protected boolean`	`getPartitionsByExprInternal(String dbName, String tblName, byte[] expr, String defaultPartitionName, short maxParts, List<Partition> result, boolean allowSql, boolean allowJdo)`
`List<Partition>`	`getPartitionsByFilter(String dbName, String tblName, String filter, short maxParts)`
`protected List<Partition>`	`getPartitionsByFilterInternal(String dbName, String tblName, String filter, short maxParts, boolean allowSql, boolean allowJdo)`
`List<Partition>`	`getPartitionsByNames(String dbName, String tblName, List<String> partNames)`
`protected List<Partition>`	`getPartitionsByNamesInternal(String dbName, String tblName, List<String> partNames, boolean allowSql, boolean allowJdo)`
`protected List<Partition>`	`getPartitionsInternal(String dbName, String tblName, int maxParts, boolean allowSql, boolean allowJdo)`
`List<Partition>`	`getPartitionsWithAuth(String dbName, String tblName, short max, String userName, List<String> groupNames)`
`Partition`	`getPartitionWithAuth(String dbName, String tblName, List<String> partVals, String user_name, List<String> group_names)`
`javax.jdo.PersistenceManager`	`getPersistenceManager()`
`Role`	`getRole(String roleName)`
`Table`	`getTable(String dbName, String tableName)`
`ColumnStatistics`	`getTableColumnStatistics(String dbName, String tableName, List<String> colNames)` Returns the relevant column statistics for a given column in a given table in a given database if such statistics exist.
`protected ColumnStatistics`	`getTableColumnStatisticsInternal(String dbName, String tableName, List<String> colNames, boolean allowSql, boolean allowJdo)`
`List<Table>`	`getTableObjectsByName(String db, List<String> tbl_names)`
`PrincipalPrivilegeSet`	`getTablePrivilegeSet(String dbName, String tableName, String userName, List<String> groupNames)`
`List<String>`	`getTables(String dbName, String pattern)`
`String`	`getToken(String tokenId)`
`Type`	`getType(String typeName)`
`PrincipalPrivilegeSet`	`getUserPrivilegeSet(String userName, List<String> groupNames)`
`boolean`	`grantPrivileges(PrivilegeBag privileges)`
`boolean`	`grantRole(Role role, String userName, PrincipalType principalType, String grantor, PrincipalType grantorType, boolean grantOption)`
`boolean`	`isActiveTransaction()`
`boolean`	`isPartitionMarkedForEvent(String dbName, String tblName, Map<String,String> partName, PartitionEventType evtType)`
`List<MTablePrivilege>`	`listAllTableGrants(String principalName, PrincipalType principalType, String dbName, String tableName)`
`List<MTablePrivilege>`	`listAllTableGrants(String dbName, String tableName)`
`List<HiveObjectPrivilege>`	`listDBGrantsAll(String dbName)`
`Set<String>`	`listFSRoots()` The following API - listFSRoots is used by HiveMetaTool.
`List<HiveObjectPrivilege>`	`listGlobalGrantsAll()`
`List<String>`	`listIndexNames(String dbName, String origTableName, short max)`
`List<MPartitionColumnPrivilege>`	`listPartitionAllColumnGrants(String dbName, String tableName, List<String> partNames)`
`List<HiveObjectPrivilege>`	`listPartitionColumnGrantsAll(String dbName, String tableName, String partitionName, String columnName)`
`List<HiveObjectPrivilege>`	`listPartitionGrantsAll(String dbName, String tableName, String partitionName)`
`List<String>`	`listPartitionNames(String dbName, String tableName, short max)`
`List<String>`	`listPartitionNamesByFilter(String dbName, String tableName, String filter, short maxParts)`
`List<String>`	`listPartitionNamesPs(String dbName, String tableName, List<String> part_vals, short max_parts)` Lists partition names that match a given partial specification
`List<Partition>`	`listPartitionsPsWithAuth(String db_name, String tbl_name, List<String> part_vals, short max_parts, String userName, List<String> groupNames)` Lists partitions that match a given partial specification and sets their auth privileges.
`List<MDBPrivilege>`	`listPrincipalDBGrants(String principalName, PrincipalType principalType, String dbName)`
`List<HiveObjectPrivilege>`	`listPrincipalDBGrantsAll(String principalName, PrincipalType principalType)`
`List<MGlobalPrivilege>`	`listPrincipalGlobalGrants(String principalName, PrincipalType principalType)`
`List<MPartitionColumnPrivilege>`	`listPrincipalPartitionColumnGrants(String principalName, PrincipalType principalType, String dbName, String tableName, String partitionName, String columnName)`
`List<HiveObjectPrivilege>`	`listPrincipalPartitionColumnGrantsAll(String principalName, PrincipalType principalType)`
`List<MPartitionPrivilege>`	`listPrincipalPartitionGrants(String principalName, PrincipalType principalType, String dbName, String tableName, String partName)`
`List<HiveObjectPrivilege>`	`listPrincipalPartitionGrantsAll(String principalName, PrincipalType principalType)`
`List<MTableColumnPrivilege>`	`listPrincipalTableColumnGrants(String principalName, PrincipalType principalType, String dbName, String tableName, String columnName)`
`List<HiveObjectPrivilege>`	`listPrincipalTableColumnGrantsAll(String principalName, PrincipalType principalType)`
`List<HiveObjectPrivilege>`	`listPrincipalTableGrantsAll(String principalName, PrincipalType principalType)`
`List<MRoleMap>`	`listRoleMembers(String roleName)` Get the role to principal grant mapping for given role
`List<String>`	`listRoleNames()`
`List<MRoleMap>`	`listRoles(String principalName, PrincipalType principalType)`
`List<MTableColumnPrivilege>`	`listTableAllColumnGrants(String dbName, String tableName)`
`List<MPartitionColumnPrivilege>`	`listTableAllPartitionColumnGrants(String dbName, String tableName)`
`List<MPartitionPrivilege>`	`listTableAllPartitionGrants(String dbName, String tableName)`
`List<HiveObjectPrivilege>`	`listTableColumnGrantsAll(String dbName, String tableName, String columnName)`
`List<HiveObjectPrivilege>`	`listTableGrantsAll(String dbName, String tableName)`
`List<String>`	`listTableNamesByFilter(String dbName, String filter, short maxTables)` Gets a list of tables based on a filter string and filter type.
`Table`	`markPartitionForEvent(String dbName, String tblName, Map<String,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(Integer id)`
`boolean`	`removeRole(String roleName)`
`boolean`	`removeToken(String tokenId)`
`boolean`	`revokePrivileges(PrivilegeBag privileges, boolean grantOption)`
`boolean`	`revokeRole(Role role, String userName, PrincipalType principalType, boolean grantOption)`
`void`	`rollbackTransaction()` Rolls back the current transaction if it is active
`void`	`setConf(org.apache.hadoop.conf.Configuration conf)` Called whenever this object is instantiated using ReflectionUtils, and also on connection retries.
`void`	`setMetaStoreSchemaVersion(String schemaVersion, String comment)`
`static void`	`setSchemaVerified(boolean val)`
`void`	`shutdown()`
`void`	`updateMasterKey(Integer id, String key)`
`ObjectStore.UpdateMDatabaseURIRetVal`	`updateMDatabaseURI(URI oldLoc, URI newLoc, boolean dryRun)` The following APIs - updateMDatabaseURI is used by HiveMetaTool.
`ObjectStore.UpdatePropURIRetVal`	`updateMStorageDescriptorTblPropURI(URI oldLoc, URI newLoc, String tblPropKey, boolean isDryRun)` Deprecated.
`ObjectStore.UpdateMStorageDescriptorTblURIRetVal`	`updateMStorageDescriptorTblURI(URI oldLoc, URI newLoc, boolean isDryRun)` The following APIs - updateMStorageDescriptorTblURI is used by HiveMetaTool.
`boolean`	`updatePartitionColumnStatistics(ColumnStatistics colStats, List<String> partVals)` Persists the given column statistics object to the metastore
`ObjectStore.UpdateSerdeURIRetVal`	`updateSerdeURI(URI oldLoc, URI newLoc, 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
`ObjectStore.UpdatePropURIRetVal`	`updateTblPropURI(URI oldLoc, URI newLoc, String tblPropKey, boolean isDryRun)` The following APIs - updateMStorageDescriptorTblPropURI is used by HiveMetaTool.
`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 org.apache.hadoop.conf.Configuration getConf()
```
Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

setConf
```
public void setConf(org.apache.hadoop.conf.Configuration conf)
```
Called whenever this object is instantiated using ReflectionUtils, and also on connection retries. In cases of connection retries, conf will usually contain modified values.

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable

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(String name)
                     throws NoSuchObjectException

Specified by:: getDatabase in interface RawStore
Throws:: NoSuchObjectException

getDatabaseInternal

public Database getDatabaseInternal(String name)
                             throws MetaException,
                                    NoSuchObjectException

Throws:: MetaException; NoSuchObjectException

getJDODatabase

public Database getJDODatabase(String name)
                        throws NoSuchObjectException

Throws:: NoSuchObjectException

alterDatabase
```
public boolean alterDatabase(String dbName,
                    Database db)
                      throws MetaException,
                             NoSuchObjectException
```
Alter the database object in metastore. Currently only the parameters of the database or the owner 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(String dbname)
                     throws NoSuchObjectException,
                            MetaException

Specified by:: dropDatabase in interface RawStore
Throws:: NoSuchObjectException; MetaException

getDatabases

public List<String> getDatabases(String pattern)
                          throws MetaException

Specified by:: getDatabases in interface RawStore
Throws:: MetaException

getAllDatabases

public List<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(String typeName)
```
Specified by:

getType in interface RawStore

dropType
```
public boolean dropType(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(String dbName,
                String tableName)
                  throws MetaException,
                         NoSuchObjectException,
                         InvalidObjectException,
                         InvalidInputException

Specified by:: dropTable in interface RawStore
Throws:: MetaException; NoSuchObjectException; InvalidObjectException; InvalidInputException

getTable

public Table getTable(String dbName,
             String tableName)
               throws MetaException

Specified by:: getTable in interface RawStore
Throws:: MetaException

getTables

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

Specified by:: getTables in interface RawStore
Throws:: MetaException

getAllTables

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

Specified by:: getAllTables in interface RawStore
Throws:: MetaException

getTableObjectsByName
```
public List<Table> getTableObjectsByName(String db,
                                List<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

addPartitions

public boolean addPartitions(String dbName,
                    String tblName,
                    List<Partition> parts)
                      throws InvalidObjectException,
                             MetaException

Specified by:: addPartitions in interface RawStore
Throws:: InvalidObjectException; MetaException

addPartitions

public boolean addPartitions(String dbName,
                    String tblName,
                    PartitionSpecProxy partitionSpec,
                    boolean ifNotExists)
                      throws InvalidObjectException,
                             MetaException

Specified by:: addPartitions in interface RawStore
Throws:: InvalidObjectException; MetaException

addPartition

public boolean addPartition(Partition part)
                     throws InvalidObjectException,
                            MetaException

Specified by:: addPartition in interface RawStore
Throws:: InvalidObjectException; MetaException

getPartition

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

Specified by:: getPartition in interface RawStore
Throws:: NoSuchObjectException; MetaException

dropPartition

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

Specified by:: dropPartition in interface RawStore
Throws:: MetaException; NoSuchObjectException; InvalidObjectException; InvalidInputException

dropPartitions

public void dropPartitions(String dbName,
                  String tblName,
                  List<String> partNames)
                    throws MetaException,
                           NoSuchObjectException

Specified by:: dropPartitions in interface RawStore
Throws:: MetaException; NoSuchObjectException

getPartitions

public List<Partition> getPartitions(String dbName,
                            String tableName,
                            int maxParts)
                              throws MetaException,
                                     NoSuchObjectException

Specified by:: getPartitions in interface RawStore
Throws:: MetaException; NoSuchObjectException

getPartitionsInternal

protected List<Partition> getPartitionsInternal(String dbName,
                                    String tblName,
                                    int maxParts,
                                    boolean allowSql,
                                    boolean allowJdo)
                                         throws MetaException,
                                                NoSuchObjectException

Throws:: MetaException; NoSuchObjectException

getPartitionsWithAuth

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

Specified by:: getPartitionsWithAuth in interface RawStore
Throws:: MetaException; NoSuchObjectException; InvalidObjectException

getPartitionWithAuth

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

Specified by:: getPartitionWithAuth in interface RawStore
Throws:: NoSuchObjectException; MetaException; InvalidObjectException

listPartitionNames

public List<String> listPartitionNames(String dbName,
                              String tableName,
                              short max)
                                throws MetaException

Specified by:: listPartitionNames in interface RawStore
Throws:: MetaException

listPartitionsPsWithAuth
```
public List<Partition> listPartitionsPsWithAuth(String db_name,
                                       String tbl_name,
                                       List<String> part_vals,
                                       short max_parts,
                                       String userName,
                                       List<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 List<String> listPartitionNamesPs(String dbName,
                                String tableName,
                                List<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 List<Partition> getPartitionsByNames(String dbName,
                                   String tblName,
                                   List<String> partNames)
                                     throws MetaException,
                                            NoSuchObjectException

Specified by:: getPartitionsByNames in interface RawStore
Throws:: MetaException; NoSuchObjectException

getPartitionsByNamesInternal

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

Throws:: MetaException; NoSuchObjectException

getPartitionsByExpr

public boolean getPartitionsByExpr(String dbName,
                          String tblName,
                          byte[] expr,
                          String defaultPartitionName,
                          short maxParts,
                          List<Partition> result)
                            throws org.apache.thrift.TException

Specified by:: getPartitionsByExpr in interface RawStore
Throws:: org.apache.thrift.TException

getPartitionsByExprInternal

protected boolean getPartitionsByExprInternal(String dbName,
                                  String tblName,
                                  byte[] expr,
                                  String defaultPartitionName,
                                  short maxParts,
                                  List<Partition> result,
                                  boolean allowSql,
                                  boolean allowJdo)
                                       throws org.apache.thrift.TException

Throws:: org.apache.thrift.TException

getPartitionsByFilter

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

Specified by:: getPartitionsByFilter in interface RawStore
Throws:: MetaException; NoSuchObjectException

getPartitionsByFilterInternal

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

Throws:: MetaException; NoSuchObjectException

listTableNamesByFilter
```
public List<String> listTableNamesByFilter(String dbName,
                                  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 List<String> listPartitionNamesByFilter(String dbName,
                                      String tableName,
                                      String filter,
                                      short maxParts)
                                        throws MetaException

Specified by:: listPartitionNamesByFilter in interface RawStore
Throws:: MetaException

alterTable

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

Specified by:: alterTable in interface RawStore
Throws:: InvalidObjectException; MetaException

alterIndex

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

Specified by:: alterIndex in interface RawStore
Throws:: InvalidObjectException; MetaException

alterPartition

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

Specified by:: alterPartition in interface RawStore
Throws:: InvalidObjectException; MetaException

alterPartitions

public void alterPartitions(String dbname,
                   String name,
                   List<List<String>> part_vals,
                   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(String dbName,
                String origTableName,
                String indexName)
                  throws MetaException

Specified by:: dropIndex in interface RawStore
Throws:: MetaException

getIndex

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

Specified by:: getIndex in interface RawStore
Throws:: MetaException

getIndexes

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

Specified by:: getIndexes in interface RawStore
Throws:: MetaException

listIndexNames

public List<String> listIndexNames(String dbName,
                          String origTableName,
                          short max)
                            throws MetaException

Specified by:: listIndexNames in interface RawStore
Throws:: MetaException

addRole

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

Specified by:: addRole in interface RawStore
Throws:: InvalidObjectException; MetaException; NoSuchObjectException

grantRole

public boolean grantRole(Role role,
                String userName,
                PrincipalType principalType,
                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,
                 String userName,
                 PrincipalType principalType,
                 boolean grantOption)
                   throws MetaException,
                          NoSuchObjectException

Specified by:: revokeRole in interface RawStore
Throws:: MetaException; NoSuchObjectException

removeRole

public boolean removeRole(String roleName)
                   throws MetaException,
                          NoSuchObjectException

Specified by:: removeRole in interface RawStore
Throws:: MetaException; NoSuchObjectException

listRoles

public List<MRoleMap> listRoles(String principalName,
                       PrincipalType principalType)

Specified by:: listRoles in interface RawStore

getRole

public Role getRole(String roleName)
             throws NoSuchObjectException

Specified by:: getRole in interface RawStore
Throws:: NoSuchObjectException

listRoleNames
```
public List<String> listRoleNames()
```
Specified by:

listRoleNames in interface RawStore

getUserPrivilegeSet

public PrincipalPrivilegeSet getUserPrivilegeSet(String userName,
                                        List<String> groupNames)
                                          throws InvalidObjectException,
                                                 MetaException

Specified by:: getUserPrivilegeSet in interface RawStore
Throws:: InvalidObjectException; MetaException

getDBPrivilege

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

Throws:: InvalidObjectException; MetaException

getDBPrivilegeSet

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

Specified by:: getDBPrivilegeSet in interface RawStore
Throws:: InvalidObjectException; MetaException

getPartitionPrivilegeSet

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

Specified by:: getPartitionPrivilegeSet in interface RawStore
Throws:: InvalidObjectException; MetaException

getTablePrivilegeSet

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

Specified by:: getTablePrivilegeSet in interface RawStore
Throws:: InvalidObjectException; MetaException

getColumnPrivilegeSet

public PrincipalPrivilegeSet getColumnPrivilegeSet(String dbName,
                                          String tableName,
                                          String partitionName,
                                          String columnName,
                                          String userName,
                                          List<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,
                       boolean grantOption)
                         throws InvalidObjectException,
                                MetaException,
                                NoSuchObjectException

Specified by:: revokePrivileges in interface RawStore
Throws:: InvalidObjectException; MetaException; NoSuchObjectException

listRoleMembers
```
public List<MRoleMap> listRoleMembers(String roleName)
```
Description copied from interface: RawStore

Get the role to principal grant mapping for given role

Specified by:

listRoleMembers in interface RawStore

Returns:

listPrincipalGlobalGrants

public List<MGlobalPrivilege> listPrincipalGlobalGrants(String principalName,
                                               PrincipalType principalType)

Specified by:: listPrincipalGlobalGrants in interface RawStore

listGlobalGrantsAll
```
public List<HiveObjectPrivilege> listGlobalGrantsAll()
```
Specified by:

listGlobalGrantsAll in interface RawStore

listPrincipalDBGrants

public List<MDBPrivilege> listPrincipalDBGrants(String principalName,
                                       PrincipalType principalType,
                                       String dbName)

Specified by:: listPrincipalDBGrants in interface RawStore

listPrincipalDBGrantsAll

public List<HiveObjectPrivilege> listPrincipalDBGrantsAll(String principalName,
                                                 PrincipalType principalType)

Specified by:: listPrincipalDBGrantsAll in interface RawStore

listDBGrantsAll

public List<HiveObjectPrivilege> listDBGrantsAll(String dbName)

Specified by:: listDBGrantsAll in interface RawStore

listAllTableGrants

public List<MTablePrivilege> listAllTableGrants(String dbName,
                                       String tableName)

listTableAllPartitionGrants

public List<MPartitionPrivilege> listTableAllPartitionGrants(String dbName,
                                                    String tableName)

listTableAllColumnGrants

public List<MTableColumnPrivilege> listTableAllColumnGrants(String dbName,
                                                   String tableName)

listTableAllPartitionColumnGrants

public List<MPartitionColumnPrivilege> listTableAllPartitionColumnGrants(String dbName,
                                                                String tableName)

listPartitionAllColumnGrants

public List<MPartitionColumnPrivilege> listPartitionAllColumnGrants(String dbName,
                                                           String tableName,
                                                           List<String> partNames)

dropPartitionAllColumnGrantsNoTxn

public void dropPartitionAllColumnGrantsNoTxn(String dbName,
                                     String tableName,
                                     List<String> partNames)

listAllTableGrants

public List<MTablePrivilege> listAllTableGrants(String principalName,
                                       PrincipalType principalType,
                                       String dbName,
                                       String tableName)

Specified by:: listAllTableGrants in interface RawStore

listPrincipalPartitionGrants

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

Specified by:: listPrincipalPartitionGrants in interface RawStore

listPrincipalTableColumnGrants

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

Specified by:: listPrincipalTableColumnGrants in interface RawStore

listPrincipalPartitionColumnGrants

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

Specified by:: listPrincipalPartitionColumnGrants in interface RawStore

listPrincipalPartitionColumnGrantsAll

public List<HiveObjectPrivilege> listPrincipalPartitionColumnGrantsAll(String principalName,
                                                              PrincipalType principalType)

Specified by:: listPrincipalPartitionColumnGrantsAll in interface RawStore

listPartitionColumnGrantsAll

public List<HiveObjectPrivilege> listPartitionColumnGrantsAll(String dbName,
                                                     String tableName,
                                                     String partitionName,
                                                     String columnName)

Specified by:: listPartitionColumnGrantsAll in interface RawStore

listPrincipalTableGrantsAll

public List<HiveObjectPrivilege> listPrincipalTableGrantsAll(String principalName,
                                                    PrincipalType principalType)

Specified by:: listPrincipalTableGrantsAll in interface RawStore

listTableGrantsAll

public List<HiveObjectPrivilege> listTableGrantsAll(String dbName,
                                           String tableName)

Specified by:: listTableGrantsAll in interface RawStore

listPrincipalPartitionGrantsAll

public List<HiveObjectPrivilege> listPrincipalPartitionGrantsAll(String principalName,
                                                        PrincipalType principalType)

Specified by:: listPrincipalPartitionGrantsAll in interface RawStore

listPartitionGrantsAll

public List<HiveObjectPrivilege> listPartitionGrantsAll(String dbName,
                                               String tableName,
                                               String partitionName)

Specified by:: listPartitionGrantsAll in interface RawStore

listPrincipalTableColumnGrantsAll

public List<HiveObjectPrivilege> listPrincipalTableColumnGrantsAll(String principalName,
                                                          PrincipalType principalType)

Specified by:: listPrincipalTableColumnGrantsAll in interface RawStore

listTableColumnGrantsAll

public List<HiveObjectPrivilege> listTableColumnGrantsAll(String dbName,
                                                 String tableName,
                                                 String columnName)

Specified by:: listTableColumnGrantsAll in interface RawStore

isPartitionMarkedForEvent

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

Specified by:: isPartitionMarkedForEvent in interface RawStore
Throws:: UnknownTableException; MetaException; InvalidPartitionException; UnknownPartitionException

markPartitionForEvent

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

Specified by:: markPartitionForEvent in interface RawStore
Throws:: MetaException; UnknownTableException; InvalidPartitionException; UnknownPartitionException

executeJDOQLSelect
```
public Collection<?> executeJDOQLSelect(String query)
```
The following API - executeJDOQLSelect is used by HiveMetaTool. This API **shouldn't** be exposed via Thrift.

executeJDOQLUpdate
```
public long executeJDOQLUpdate(String query)
```
The following API - executeJDOQLUpdate is used by HiveMetaTool. This API **shouldn't** be exposed via Thrift.

listFSRoots
```
public Set<String> listFSRoots()
```
The following API - listFSRoots is used by HiveMetaTool. This API **shouldn't** be exposed via Thrift.

updateMDatabaseURI

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

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

updateTblPropURI

public ObjectStore.UpdatePropURIRetVal updateTblPropURI(URI oldLoc,
                                               URI newLoc,
                                               String tblPropKey,
                                               boolean isDryRun)

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

updateMStorageDescriptorTblPropURI

@Deprecated
public ObjectStore.UpdatePropURIRetVal updateMStorageDescriptorTblPropURI(URI oldLoc,
                                                                            URI newLoc,
                                                                            String tblPropKey,
                                                                            boolean isDryRun)

Deprecated.

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

updateMStorageDescriptorTblURI

public ObjectStore.UpdateMStorageDescriptorTblURIRetVal updateMStorageDescriptorTblURI(URI oldLoc,
                                                                              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(URI oldLoc,
                                              URI newLoc,
                                              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,
                                      List<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(String dbName,
                                        String tableName,
                                        List<String> colNames)
                                          throws MetaException,
                                                 NoSuchObjectException

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

getTableColumnStatisticsInternal

protected ColumnStatistics getTableColumnStatisticsInternal(String dbName,
                                                String tableName,
                                                List<String> colNames,
                                                boolean allowSql,
                                                boolean allowJdo)
                                                     throws MetaException,
                                                            NoSuchObjectException

Throws:: MetaException; NoSuchObjectException

getPartitionColumnStatistics

public List<ColumnStatistics> getPartitionColumnStatistics(String dbName,
                                                  String tableName,
                                                  List<String> partNames,
                                                  List<String> colNames)
                                                    throws MetaException,
                                                           NoSuchObjectException

Description copied from interface: RawStore

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

Specified by:: getPartitionColumnStatistics in interface RawStore
Throws:: MetaException; NoSuchObjectException

getPartitionColumnStatisticsInternal

protected List<ColumnStatistics> getPartitionColumnStatisticsInternal(String dbName,
                                                          String tableName,
                                                          List<String> partNames,
                                                          List<String> colNames,
                                                          boolean allowSql,
                                                          boolean allowJdo)
                                                               throws MetaException,
                                                                      NoSuchObjectException

Throws:: MetaException; NoSuchObjectException

get_aggr_stats_for

public AggrStats get_aggr_stats_for(String dbName,
                           String tblName,
                           List<String> partNames,
                           List<String> colNames)
                             throws MetaException,
                                    NoSuchObjectException

Specified by:: get_aggr_stats_for in interface RawStore
Throws:: MetaException; NoSuchObjectException

deletePartitionColumnStatistics

public boolean deletePartitionColumnStatistics(String dbName,
                                      String tableName,
                                      String partName,
                                      List<String> partVals,
                                      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(String dbName,
                                  String tableName,
                                  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(String tokenId,
               String delegationToken)

Specified by:: addToken in interface RawStore

removeToken
```
public boolean removeToken(String tokenId)
```
Specified by:

removeToken in interface RawStore

getToken
```
public String getToken(String tokenId)
```
Specified by:

getToken in interface RawStore

getAllTokenIdentifiers
```
public List<String> getAllTokenIdentifiers()
```
Specified by:

getAllTokenIdentifiers in interface RawStore

addMasterKey

public int addMasterKey(String key)
                 throws MetaException

Specified by:: addMasterKey in interface RawStore
Throws:: MetaException

updateMasterKey

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

Specified by:: updateMasterKey in interface RawStore
Throws:: NoSuchObjectException; MetaException

removeMasterKey
```
public boolean removeMasterKey(Integer id)
```
Specified by:

removeMasterKey in interface RawStore

getMasterKeys
```
public String[] getMasterKeys()
```
Specified by:

getMasterKeys in interface RawStore

verifySchema
```
public void verifySchema()
                  throws MetaException
```
Specified by:

verifySchema in interface RawStore

Throws:

MetaException

setSchemaVerified

public static void setSchemaVerified(boolean val)

getMetaStoreSchemaVersion
```
public String getMetaStoreSchemaVersion()
                                 throws MetaException
```
Specified by:

getMetaStoreSchemaVersion in interface RawStore

Throws:

MetaException

setMetaStoreSchemaVersion

public void setMetaStoreSchemaVersion(String schemaVersion,
                             String comment)
                               throws MetaException

Specified by:: setMetaStoreSchemaVersion in interface RawStore
Throws:: MetaException

doesPartitionExist

public boolean doesPartitionExist(String dbName,
                         String tableName,
                         List<String> partVals)
                           throws MetaException

Specified by:: doesPartitionExist in interface RawStore
Throws:: MetaException

createFunction
```
public void createFunction(Function func)
                    throws InvalidObjectException,
                           MetaException
```
Description copied from interface: RawStore

Register a user-defined function based on the function specification passed in.

Specified by:

createFunction in interface RawStore

Throws:

InvalidObjectException

MetaException

alterFunction

public void alterFunction(String dbName,
                 String funcName,
                 Function newFunction)
                   throws InvalidObjectException,
                          MetaException

Description copied from interface: RawStore

Alter function based on new function specs.

Specified by:: alterFunction in interface RawStore
Throws:: InvalidObjectException; MetaException

dropFunction

public void dropFunction(String dbName,
                String funcName)
                  throws MetaException,
                         NoSuchObjectException,
                         InvalidObjectException,
                         InvalidInputException

Description copied from interface: RawStore

Drop a function definition.

Specified by:: dropFunction in interface RawStore
Throws:: MetaException; NoSuchObjectException; InvalidObjectException; InvalidInputException

getFunction

public Function getFunction(String dbName,
                   String funcName)
                     throws MetaException

Description copied from interface: RawStore

Retrieve function by name.

Specified by:: getFunction in interface RawStore
Returns:
Throws:: MetaException

getFunctions
```
public List<String> getFunctions(String dbName,
                        String pattern)
                          throws MetaException
```
Description copied from interface: RawStore

Retrieve list of function names based on name pattern.

Specified by:

getFunctions in interface RawStore

Returns:

Throws:

MetaException

getNextNotification
```
public NotificationEventResponse getNextNotification(NotificationEventRequest rqst)
```
Description copied from interface: RawStore

Get the next notification event.

Specified by:

getNextNotification in interface RawStore

Parameters:
rqst - Request containing information on the last processed notification.

Returns:
list of notifications, sorted by eventId

addNotificationEvent
```
public void addNotificationEvent(NotificationEvent entry)
```
Description copied from interface: RawStore

Add a notification entry. This should only be called from inside the metastore

Specified by:

addNotificationEvent in interface RawStore

Parameters:
entry - the notification to add

cleanNotificationEvents
```
public void cleanNotificationEvents(int olderThan)
```
Description copied from interface: RawStore

Remove older notification events.

Specified by:

cleanNotificationEvents in interface RawStore

Parameters:
olderThan - Remove any events older than a given number of seconds

getCurrentNotificationEventId
```
public CurrentNotificationEventId getCurrentNotificationEventId()
```
Description copied from interface: RawStore

Get the last issued notification event id. This is intended for use by the export command so that users can determine the state of the system at the point of the export, and determine which notification events happened before or after the export.

Specified by:

getCurrentNotificationEventId in interface RawStore

Returns:

Class ObjectStore

Nested Class Summary

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

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

ObjectStore

Method Detail

getConf

setConf

getPersistenceManager

shutdown

openTransaction

commitTransaction

isActiveTransaction

rollbackTransaction

createDatabase

getDatabase

getDatabaseInternal

getJDODatabase

alterDatabase

dropDatabase

getDatabases

getAllDatabases

createType

getType

dropType

createTable

dropTable

getTable

getTables

getAllTables

getTableObjectsByName

addPartitions

addPartitions

addPartition

getPartition

dropPartition

dropPartitions

getPartitions

getPartitionsInternal

getPartitionsWithAuth

getPartitionWithAuth

listPartitionNames

listPartitionsPsWithAuth

listPartitionNamesPs

getPartitionsByNames

getPartitionsByNamesInternal

getPartitionsByExpr

getPartitionsByExprInternal

getPartitionsByFilter

getPartitionsByFilterInternal

listTableNamesByFilter

listPartitionNamesByFilter

alterTable

alterIndex

alterPartition

alterPartitions

addIndex

dropIndex

getIndex

getIndexes

listIndexNames

addRole

grantRole

revokeRole

removeRole

listRoles

getRole

listRoleNames

getUserPrivilegeSet

getDBPrivilege

getDBPrivilegeSet

getPartitionPrivilegeSet

getTablePrivilegeSet

getColumnPrivilegeSet

grantPrivileges

revokePrivileges

listRoleMembers