org.apache.hadoop.hive.metastore

Interface RawStore

All Superinterfaces:

org.apache.hadoop.conf.Configurable

All Known Implementing Classes:

ObjectStore

public interface RawStore
extends org.apache.hadoop.conf.Configurable

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	RawStore.CanNotRetry Annotation to skip retries

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addIndex(Index index)
int	addMasterKey(String key)
void	addNotificationEvent(NotificationEvent event) 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 rowName, String ownerName)
boolean	addToken(String tokenIdentifier, String delegationToken)
boolean	alterDatabase(String dbname, Database db)
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 db_name, String tbl_name, List<String> part_vals, Partition new_part)
void	alterPartitions(String db_name, String tbl_name, List<List<String>> part_vals_list, List<Partition> new_parts)
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> part_vals)
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	dropPartitions(String dbName, String tblName, List<String> partNames)
boolean	dropTable(String dbName, String tableName)
boolean	dropType(String typeName)
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)
CurrentNotificationEventId	getCurrentNotificationEventId() Get the last issued notification event id.
Database	getDatabase(String name)
List<String>	getDatabases(String pattern)
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)
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 tblName, 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.
PrincipalPrivilegeSet	getPartitionPrivilegeSet(String dbName, String tableName, String partition, String userName, List<String> groupNames)
List<Partition>	getPartitions(String dbName, String tableName, int max)
boolean	getPartitionsByExpr(String dbName, String tblName, byte[] expr, String defaultPartitionName, short maxParts, List<Partition> result)
List<Partition>	getPartitionsByFilter(String dbName, String tblName, String filter, short maxParts)
List<Partition>	getPartitionsByNames(String dbName, String tblName, List<String> partNames)
List<Partition>	getPartitionsWithAuth(String dbName, String tblName, short maxParts, String userName, List<String> groupNames)
Partition	getPartitionWithAuth(String dbName, String tblName, List<String> partVals, String user_name, List<String> group_names)
Role	getRole(String roleName)
Table	getTable(String dbName, String tableName)
ColumnStatistics	getTableColumnStatistics(String dbName, String tableName, List<String> colName) Returns the relevant column statistics for a given column in a given table in a given database if such statistics exist.
List<Table>	getTableObjectsByName(String dbname, List<String> tableNames)
PrincipalPrivilegeSet	getTablePrivilegeSet(String dbName, String tableName, String userName, List<String> groupNames)
List<String>	getTables(String dbName, String pattern)
String	getToken(String tokenIdentifier)
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	isPartitionMarkedForEvent(String dbName, String tblName, Map<String,String> partName, PartitionEventType evtType)
List<MTablePrivilege>	listAllTableGrants(String principalName, PrincipalType principalType, String dbName, String tableName)
List<HiveObjectPrivilege>	listDBGrantsAll(String dbName)
List<HiveObjectPrivilege>	listGlobalGrantsAll()
List<String>	listIndexNames(String dbName, String origTableName, short max)
List<HiveObjectPrivilege>	listPartitionColumnGrantsAll(String dbName, String tableName, String partitionName, String columnName)
List<HiveObjectPrivilege>	listPartitionGrantsAll(String dbName, String tableName, String partitionName)
List<String>	listPartitionNames(String db_name, String tbl_name, short max_parts)
List<String>	listPartitionNamesByFilter(String db_name, String tbl_name, String filter, short max_parts)
List<String>	listPartitionNamesPs(String db_name, String tbl_name, 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 partName, 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<HiveObjectPrivilege>	listTableColumnGrantsAll(String dbName, String tableName, String columnName)
List<HiveObjectPrivilege>	listTableGrantsAll(String dbName, String tableName)
List<String>	listTableNamesByFilter(String dbName, String filter, short max_tables) Gets a list of tables based on a filter string and filter type.
Table	markPartitionForEvent(String dbName, String tblName, Map<String,String> partVals, 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 keySeq)
boolean	removeRole(String roleName)
boolean	removeToken(String tokenIdentifier)
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	setMetaStoreSchemaVersion(String version, String comment)
void	shutdown()
void	updateMasterKey(Integer seqNo, String key)
boolean	updatePartitionColumnStatistics(ColumnStatistics statsObj, List<String> partVals) Persists the given column statistics object to the metastore
boolean	updateTableColumnStatistics(ColumnStatistics colStats) Persists the given column statistics object to the metastore
void	verifySchema()

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Method Detail

shutdown

void shutdown()

openTransaction

boolean openTransaction()

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

Returns:

an active transaction

commitTransaction

boolean commitTransaction()

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

Returns:

true or false

rollbackTransaction

void rollbackTransaction()

Rolls back the current transaction if it is active

createDatabase

void createDatabase(Database db)
                    throws InvalidObjectException,
                           MetaException

Throws:

InvalidObjectException

MetaException

getDatabase

Database getDatabase(String name)
                     throws NoSuchObjectException

Throws:

NoSuchObjectException

dropDatabase

boolean dropDatabase(String dbname)
                     throws NoSuchObjectException,
                            MetaException

Throws:

NoSuchObjectException

MetaException

alterDatabase

boolean alterDatabase(String dbname,
                    Database db)
                      throws NoSuchObjectException,
                             MetaException

Throws:

NoSuchObjectException

MetaException

getDatabases

List<String> getDatabases(String pattern)
                          throws MetaException

Throws:

MetaException

getAllDatabases

List<String> getAllDatabases()
                             throws MetaException

Throws:

MetaException

createType

boolean createType(Type type)

getType

Type getType(String typeName)

dropType

boolean dropType(String typeName)

createTable

void createTable(Table tbl)
                 throws InvalidObjectException,
                        MetaException

Throws:

InvalidObjectException

MetaException

dropTable

boolean dropTable(String dbName,
                String tableName)
                  throws MetaException,
                         NoSuchObjectException,
                         InvalidObjectException,
                         InvalidInputException

Throws:

MetaException

NoSuchObjectException

InvalidObjectException

InvalidInputException

getTable

Table getTable(String dbName,
             String tableName)
               throws MetaException

Throws:

MetaException

addPartition

boolean addPartition(Partition part)
                     throws InvalidObjectException,
                            MetaException

Throws:

InvalidObjectException

MetaException

addPartitions

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

Throws:

InvalidObjectException

MetaException

addPartitions

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

Throws:

InvalidObjectException

MetaException

getPartition

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

Throws:

MetaException

NoSuchObjectException

doesPartitionExist

boolean doesPartitionExist(String dbName,
                         String tableName,
                         List<String> part_vals)
                           throws MetaException,
                                  NoSuchObjectException

Throws:

MetaException

NoSuchObjectException

dropPartition

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

Throws:

MetaException

NoSuchObjectException

InvalidObjectException

InvalidInputException

getPartitions

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

Throws:

MetaException

NoSuchObjectException

alterTable

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

Throws:

InvalidObjectException

MetaException

getTables

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

Throws:

MetaException

getTableObjectsByName

List<Table> getTableObjectsByName(String dbname,
                                List<String> tableNames)
                                  throws MetaException,
                                         UnknownDBException

Parameters:

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

tableNames - 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

getAllTables

List<String> getAllTables(String dbName)
                          throws MetaException

Throws:

MetaException

listTableNamesByFilter

List<String> listTableNamesByFilter(String dbName,
                                  String filter,
                                  short max_tables)
                                    throws MetaException,
                                           UnknownDBException

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

Parameters:

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

filter - The filter string

max_tables - The maximum number of tables returned

Returns:

A list of table names that match the desired filter

Throws:

MetaException

UnknownDBException

listPartitionNames

List<String> listPartitionNames(String db_name,
                              String tbl_name,
                              short max_parts)
                                throws MetaException

Throws:

MetaException

listPartitionNamesByFilter

List<String> listPartitionNamesByFilter(String db_name,
                                      String tbl_name,
                                      String filter,
                                      short max_parts)
                                        throws MetaException

Throws:

MetaException

alterPartition

void alterPartition(String db_name,
                  String tbl_name,
                  List<String> part_vals,
                  Partition new_part)
                    throws InvalidObjectException,
                           MetaException

Throws:

InvalidObjectException

MetaException

alterPartitions

void alterPartitions(String db_name,
                   String tbl_name,
                   List<List<String>> part_vals_list,
                   List<Partition> new_parts)
                     throws InvalidObjectException,
                            MetaException

Throws:

InvalidObjectException

MetaException

addIndex

boolean addIndex(Index index)
                 throws InvalidObjectException,
                        MetaException

Throws:

InvalidObjectException

MetaException

getIndex

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

Throws:

MetaException

dropIndex

boolean dropIndex(String dbName,
                String origTableName,
                String indexName)
                  throws MetaException

Throws:

MetaException

getIndexes

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

Throws:

MetaException

listIndexNames

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

Throws:

MetaException

alterIndex

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

Throws:

InvalidObjectException

MetaException

getPartitionsByFilter

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

Throws:

MetaException

NoSuchObjectException

getPartitionsByExpr

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

Throws:

org.apache.thrift.TException

getPartitionsByNames

List<Partition> getPartitionsByNames(String dbName,
                                   String tblName,
                                   List<String> partNames)
                                     throws MetaException,
                                            NoSuchObjectException

Throws:

MetaException

NoSuchObjectException

markPartitionForEvent

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

Throws:

MetaException

UnknownTableException

InvalidPartitionException

UnknownPartitionException

isPartitionMarkedForEvent

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

Throws:

MetaException

UnknownTableException

InvalidPartitionException

UnknownPartitionException

addRole

boolean addRole(String rowName,
              String ownerName)
                throws InvalidObjectException,
                       MetaException,
                       NoSuchObjectException

Throws:

InvalidObjectException

MetaException

NoSuchObjectException

removeRole

boolean removeRole(String roleName)
                   throws MetaException,
                          NoSuchObjectException

Throws:

MetaException

NoSuchObjectException

grantRole

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

Throws:

MetaException

NoSuchObjectException

InvalidObjectException

revokeRole

boolean revokeRole(Role role,
                 String userName,
                 PrincipalType principalType,
                 boolean grantOption)
                   throws MetaException,
                          NoSuchObjectException

Throws:

MetaException

NoSuchObjectException

getUserPrivilegeSet

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

Throws:

InvalidObjectException

MetaException

getDBPrivilegeSet

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

Throws:

InvalidObjectException

MetaException

getTablePrivilegeSet

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

Throws:

InvalidObjectException

MetaException

getPartitionPrivilegeSet

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

Throws:

InvalidObjectException

MetaException

getColumnPrivilegeSet

PrincipalPrivilegeSet getColumnPrivilegeSet(String dbName,
                                          String tableName,
                                          String partitionName,
                                          String columnName,
                                          String userName,
                                          List<String> groupNames)
                                            throws InvalidObjectException,
                                                   MetaException

Throws:

InvalidObjectException

MetaException

listPrincipalGlobalGrants

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

listPrincipalDBGrants

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

listAllTableGrants

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

listPrincipalPartitionGrants

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

listPrincipalTableColumnGrants

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

listPrincipalPartitionColumnGrants

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

grantPrivileges

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

Throws:

InvalidObjectException

MetaException

NoSuchObjectException

revokePrivileges

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

Throws:

InvalidObjectException

MetaException

NoSuchObjectException

getRole

Role getRole(String roleName)
             throws NoSuchObjectException

Throws:

NoSuchObjectException

listRoleNames

List<String> listRoleNames()

listRoles

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

listRoleMembers

List<MRoleMap> listRoleMembers(String roleName)

Get the role to principal grant mapping for given role

Parameters:

roleName -

Returns:

getPartitionWithAuth

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

Throws:

MetaException

NoSuchObjectException

InvalidObjectException

getPartitionsWithAuth

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

Throws:

MetaException

NoSuchObjectException

InvalidObjectException

listPartitionNamesPs

List<String> listPartitionNamesPs(String db_name,
                                String tbl_name,
                                List<String> part_vals,
                                short max_parts)
                                  throws MetaException,
                                         NoSuchObjectException

Lists partition names that match a given partial specification

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

listPartitionsPsWithAuth

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

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

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

NoSuchObjectException

InvalidObjectException

updateTableColumnStatistics

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

Persists the given column statistics object to the metastore

Parameters:

partVals -

ColumnStats - object to persist

List - of partVals

Returns:

Boolean indicating the outcome of the operation

Throws:

NoSuchObjectException

MetaException

InvalidObjectException

InvalidInputException

updatePartitionColumnStatistics

boolean updatePartitionColumnStatistics(ColumnStatistics statsObj,
                                      List<String> partVals)
                                        throws NoSuchObjectException,
                                               MetaException,
                                               InvalidObjectException,
                                               InvalidInputException

Persists the given column statistics object to the metastore

Parameters:

partVals -

ColumnStats - object to persist

List - of partVals

Returns:

Boolean indicating the outcome of the operation

Throws:

NoSuchObjectException

MetaException

InvalidObjectException

InvalidInputException

getTableColumnStatistics

ColumnStatistics getTableColumnStatistics(String dbName,
                                        String tableName,
                                        List<String> colName)
                                          throws MetaException,
                                                 NoSuchObjectException

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

Parameters:

The - name of the database, defaults to current database

The - name of the table

The - name of the column for which statistics is requested

Returns:

Relevant column statistics for the column for the given table

Throws:

NoSuchObjectException

MetaException

InvalidInputException

getPartitionColumnStatistics

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

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

Throws:

MetaException

NoSuchObjectException

deletePartitionColumnStatistics

boolean deletePartitionColumnStatistics(String dbName,
                                      String tableName,
                                      String partName,
                                      List<String> partVals,
                                      String colName)
                                        throws NoSuchObjectException,
                                               MetaException,
                                               InvalidObjectException,
                                               InvalidInputException

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.

Parameters:

dbName -

tableName -

partName -

partVals -

colName -

Returns:

Boolean indicating the outcome of the operation

Throws:

NoSuchObjectException

MetaException

InvalidObjectException

InvalidInputException

deleteTableColumnStatistics

boolean deleteTableColumnStatistics(String dbName,
                                  String tableName,
                                  String colName)
                                    throws NoSuchObjectException,
                                           MetaException,
                                           InvalidObjectException,
                                           InvalidInputException

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.

Parameters:

dbName -

tableName -

colName -

Returns:

Boolean indicating the outcome of the operation

Throws:

NoSuchObjectException

MetaException

InvalidObjectException

InvalidInputException

cleanupEvents

long cleanupEvents()

addToken

boolean addToken(String tokenIdentifier,
               String delegationToken)

removeToken

boolean removeToken(String tokenIdentifier)

getToken

String getToken(String tokenIdentifier)

getAllTokenIdentifiers

List<String> getAllTokenIdentifiers()

addMasterKey

int addMasterKey(String key)
                 throws MetaException

Throws:

MetaException

updateMasterKey

void updateMasterKey(Integer seqNo,
                   String key)
                     throws NoSuchObjectException,
                            MetaException

Throws:

NoSuchObjectException

MetaException

removeMasterKey

boolean removeMasterKey(Integer keySeq)

getMasterKeys

String[] getMasterKeys()

verifySchema

void verifySchema()
                  throws MetaException

Throws:

MetaException

getMetaStoreSchemaVersion

String getMetaStoreSchemaVersion()
                                 throws MetaException

Throws:

MetaException

setMetaStoreSchemaVersion

void setMetaStoreSchemaVersion(String version,
                             String comment)
                               throws MetaException

Throws:

MetaException

dropPartitions

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

Throws:

MetaException

NoSuchObjectException

listPrincipalDBGrantsAll

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

listPrincipalTableGrantsAll

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

listPrincipalPartitionGrantsAll

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

listPrincipalTableColumnGrantsAll

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

listPrincipalPartitionColumnGrantsAll

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

listGlobalGrantsAll

List<HiveObjectPrivilege> listGlobalGrantsAll()

listDBGrantsAll

List<HiveObjectPrivilege> listDBGrantsAll(String dbName)

listPartitionColumnGrantsAll

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

listTableGrantsAll

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

listPartitionGrantsAll

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

listTableColumnGrantsAll

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

createFunction

void createFunction(Function func)
                    throws InvalidObjectException,
                           MetaException

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

Parameters:

func -

Throws:

InvalidObjectException

MetaException

alterFunction

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

Alter function based on new function specs.

Parameters:

dbName -

name -

newFunction -

Throws:

InvalidObjectException

MetaException

dropFunction

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

Drop a function definition.

Parameters:

dbName -

functionName -

Throws:

MetaException

NoSuchObjectException

InvalidObjectException

InvalidInputException

getFunction

Function getFunction(String dbName,
                   String funcName)
                     throws MetaException

Retrieve function by name.

Parameters:

dbName -

functionName -

Returns:

Throws:

MetaException

getFunctions

List<String> getFunctions(String dbName,
                        String pattern)
                          throws MetaException

Retrieve list of function names based on name pattern.

Parameters:

dbName -

pattern -

Returns:

Throws:

MetaException

get_aggr_stats_for

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

Throws:

MetaException

NoSuchObjectException

getNextNotification

NotificationEventResponse getNextNotification(NotificationEventRequest rqst)

Get the next notification event.

Parameters:

rqst - Request containing information on the last processed notification.

Returns:

list of notifications, sorted by eventId

addNotificationEvent

void addNotificationEvent(NotificationEvent event)

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

Parameters:

event - the notification to add

cleanNotificationEvents

void cleanNotificationEvents(int olderThan)

Remove older notification events.

Parameters:

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

getCurrentNotificationEventId

CurrentNotificationEventId getCurrentNotificationEventId()

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.

Returns: