org.apache.hadoop.hive.metastore

Interface RawStore

All Superinterfaces:

org.apache.hadoop.conf.Configurable

All Known Implementing Classes:

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

Modifier and Type	Method and Description
List<String>	addCheckConstraints(List<org.apache.hadoop.hive.metastore.api.SQLCheckConstraint> cc) Add check constraints to a table
List<String>	addDefaultConstraints(List<org.apache.hadoop.hive.metastore.api.SQLDefaultConstraint> dv) Add default values to a table definition
List<String>	addForeignKeys(List<org.apache.hadoop.hive.metastore.api.SQLForeignKey> fks) Add a foreign key to a table.
int	addMasterKey(String key)
void	addNotificationEvent(org.apache.hadoop.hive.metastore.api.NotificationEvent event) Add a notification entry.
List<String>	addNotNullConstraints(List<org.apache.hadoop.hive.metastore.api.SQLNotNullConstraint> nns) Add not null constraints to a table.
boolean	addPartition(org.apache.hadoop.hive.metastore.api.Partition part) Add a partition.
boolean	addPartitions(String catName, String dbName, String tblName, List<org.apache.hadoop.hive.metastore.api.Partition> parts) Add a list of partitions to a table.
boolean	addPartitions(String catName, String dbName, String tblName, PartitionSpecProxy partitionSpec, boolean ifNotExists) Add a list of partitions to a table.
List<String>	addPrimaryKeys(List<org.apache.hadoop.hive.metastore.api.SQLPrimaryKey> pks) Add a primary key to a table.
boolean	addRole(String rowName, String ownerName)
void	addRuntimeStat(org.apache.hadoop.hive.metastore.api.RuntimeStat stat) Adds a RuntimeStat for persistence.
void	addSchemaVersion(org.apache.hadoop.hive.metastore.api.SchemaVersion schemaVersion) Create a new version of an existing schema.
void	addSerde(org.apache.hadoop.hive.metastore.api.SerDeInfo serde) Add a serde
boolean	addToken(String tokenIdentifier, String delegationToken)
List<String>	addUniqueConstraints(List<org.apache.hadoop.hive.metastore.api.SQLUniqueConstraint> uks) Add unique constraints to a table.
void	alterCatalog(String catName, org.apache.hadoop.hive.metastore.api.Catalog cat) Alter an existing catalog.
boolean	alterDatabase(String catalogName, String dbname, org.apache.hadoop.hive.metastore.api.Database db) Alter a database.
void	alterFunction(String catName, String dbName, String funcName, org.apache.hadoop.hive.metastore.api.Function newFunction) Alter function based on new function specs.
void	alterISchema(org.apache.hadoop.hive.metastore.api.ISchemaName schemaName, org.apache.hadoop.hive.metastore.api.ISchema newSchema) Alter an existing ISchema.
void	alterPartition(String catName, String db_name, String tbl_name, List<String> part_vals, org.apache.hadoop.hive.metastore.api.Partition new_part) Alter a partition.
void	alterPartitions(String catName, String db_name, String tbl_name, List<List<String>> part_vals_list, List<org.apache.hadoop.hive.metastore.api.Partition> new_parts) Alter a set of partitions.
void	alterPool(org.apache.hadoop.hive.metastore.api.WMNullablePool pool, String poolPath)
org.apache.hadoop.hive.metastore.api.WMFullResourcePlan	alterResourcePlan(String name, org.apache.hadoop.hive.metastore.api.WMNullableResourcePlan resourcePlan, boolean canActivateDisabled, boolean canDeactivate, boolean isReplace)
void	alterSchemaVersion(org.apache.hadoop.hive.metastore.api.SchemaVersionDescriptor version, org.apache.hadoop.hive.metastore.api.SchemaVersion newVersion) Alter a schema version.
void	alterTable(String catName, String dbname, String name, org.apache.hadoop.hive.metastore.api.Table newTable) Alter a table.
void	alterWMTrigger(org.apache.hadoop.hive.metastore.api.WMTrigger trigger)
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	createCatalog(org.apache.hadoop.hive.metastore.api.Catalog cat) Create a new catalog.
void	createDatabase(org.apache.hadoop.hive.metastore.api.Database db) Create a database.
void	createFunction(org.apache.hadoop.hive.metastore.api.Function func) Register a user-defined function based on the function specification passed in.
void	createISchema(org.apache.hadoop.hive.metastore.api.ISchema schema) Create a new ISchema.
void	createOrUpdateWMMapping(org.apache.hadoop.hive.metastore.api.WMMapping mapping, boolean update)
void	createPool(org.apache.hadoop.hive.metastore.api.WMPool pool)
void	createResourcePlan(org.apache.hadoop.hive.metastore.api.WMResourcePlan resourcePlan, String copyFrom, int defaultPoolSize)
void	createTable(org.apache.hadoop.hive.metastore.api.Table tbl)
List<String>	createTableWithConstraints(org.apache.hadoop.hive.metastore.api.Table tbl, List<org.apache.hadoop.hive.metastore.api.SQLPrimaryKey> primaryKeys, List<org.apache.hadoop.hive.metastore.api.SQLForeignKey> foreignKeys, List<org.apache.hadoop.hive.metastore.api.SQLUniqueConstraint> uniqueConstraints, List<org.apache.hadoop.hive.metastore.api.SQLNotNullConstraint> notNullConstraints, List<org.apache.hadoop.hive.metastore.api.SQLDefaultConstraint> defaultConstraints, List<org.apache.hadoop.hive.metastore.api.SQLCheckConstraint> checkConstraints) Create a table with constraints
boolean	createType(org.apache.hadoop.hive.metastore.api.Type type)
void	createWMTrigger(org.apache.hadoop.hive.metastore.api.WMTrigger trigger)
void	createWMTriggerToPoolMapping(String resourcePlanName, String triggerName, String poolPath)
boolean	deletePartitionColumnStatistics(String catName, 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.
int	deleteRuntimeStats(int maxRetainSecs) Removes outdated statistics.
boolean	deleteTableColumnStatistics(String catName, String dbName, String tableName, String colName) Delete statistics for a single column or all columns in a table.
boolean	doesPartitionExist(String catName, String dbName, String tableName, List<String> part_vals) Check whether a partition exists.
void	dropCatalog(String catalogName) Drop a catalog.
default void	dropConstraint(String catName, String dbName, String tableName, String constraintName) Drop a constraint, any constraint.
void	dropConstraint(String catName, String dbName, String tableName, String constraintName, boolean missingOk) Drop a constraint, any constraint.
boolean	dropDatabase(String catalogName, String dbname) Drop a database.
void	dropFunction(String catName, String dbName, String funcName) Drop a function definition.
void	dropISchema(org.apache.hadoop.hive.metastore.api.ISchemaName schemaName) Drop an ISchema.
boolean	dropPartition(String catName, String dbName, String tableName, List<String> part_vals) Drop a partition.
void	dropPartitions(String catName, String dbName, String tblName, List<String> partNames) Drop a list of partitions.
void	dropResourcePlan(String name)
void	dropSchemaVersion(org.apache.hadoop.hive.metastore.api.SchemaVersionDescriptor version) Drop a version of the schema.
boolean	dropTable(String catalogName, String dbName, String tableName) Drop a table.
boolean	dropType(String typeName)
void	dropWMMapping(org.apache.hadoop.hive.metastore.api.WMMapping mapping)
void	dropWMPool(String resourcePlanName, String poolPath)
void	dropWMTrigger(String resourcePlanName, String triggerName)
void	dropWMTriggerToPoolMapping(String resourcePlanName, String triggerName, String poolPath)
void	flushCache()
org.apache.hadoop.hive.metastore.api.AggrStats	get_aggr_stats_for(String catName, String dbName, String tblName, List<String> partNames, List<String> colNames) Get aggregated stats for a table or partition(s).
org.apache.hadoop.hive.metastore.api.WMFullResourcePlan	getActiveResourcePlan()
List<String>	getAllDatabases(String catalogName) Get names of all the databases in a catalog.
List<org.apache.hadoop.hive.metastore.api.Function>	getAllFunctions(String catName) Retrieve all functions.
List<org.apache.hadoop.hive.metastore.api.WMResourcePlan>	getAllResourcePlans()
List<org.apache.hadoop.hive.metastore.api.SchemaVersion>	getAllSchemaVersion(org.apache.hadoop.hive.metastore.api.ISchemaName schemaName) Get all of the versions of a schema
List<MetaStoreUtils.FullTableName>	getAllTableNamesForStats()
List<String>	getAllTables(String catName, String dbName) Get all tables in a database.
List<String>	getAllTokenIdentifiers()
org.apache.hadoop.hive.metastore.api.Catalog	getCatalog(String catalogName) Get a catalog.
List<String>	getCatalogs() Get all the catalogs.
List<org.apache.hadoop.hive.metastore.api.SQLCheckConstraint>	getCheckConstraints(String catName, String db_name, String tbl_name) Get check constraints for columns in a table.
org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet	getColumnPrivilegeSet(String catName, String dbName, String tableName, String partitionName, String columnName, String userName, List<String> groupNames) Get privileges for a column in a table or partition for a user.
org.apache.hadoop.hive.metastore.api.CurrentNotificationEventId	getCurrentNotificationEventId() Get the last issued notification event id.
org.apache.hadoop.hive.metastore.api.Database	getDatabase(String catalogName, String name) Get a database.
int	getDatabaseCount() Gets total number of databases.
List<String>	getDatabases(String catalogName, String pattern) Get all database in a catalog having names that match a pattern.
org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet	getDBPrivilegeSet(String catName, String dbName, String userName, List<String> groupNames) Get privileges for a database for a user.
List<org.apache.hadoop.hive.metastore.api.SQLDefaultConstraint>	getDefaultConstraints(String catName, String db_name, String tbl_name) Get default values for columns in a table.
ByteBuffer[]	getFileMetadata(List<Long> fileIds)
void	getFileMetadataByExpr(List<Long> fileIds, org.apache.hadoop.hive.metastore.api.FileMetadataExprType type, byte[] expr, ByteBuffer[] metadatas, ByteBuffer[] exprResults, boolean[] eliminated) Gets file metadata from cache after applying a format-specific expression that can produce additional information based on file metadata and also filter the file list.
FileMetadataHandler	getFileMetadataHandler(org.apache.hadoop.hive.metastore.api.FileMetadataExprType type) Gets file metadata handler for the corresponding type.
List<org.apache.hadoop.hive.metastore.api.SQLForeignKey>	getForeignKeys(String catName, String parent_db_name, String parent_tbl_name, String foreign_db_name, String foreign_tbl_name) Get the foreign keys for a table.
org.apache.hadoop.hive.metastore.api.Function	getFunction(String catName, String dbName, String funcName) Retrieve function by name.
List<String>	getFunctions(String catName, String dbName, String pattern) Retrieve list of function names based on name pattern.
org.apache.hadoop.hive.metastore.api.ISchema	getISchema(org.apache.hadoop.hive.metastore.api.ISchemaName schemaName) Get an ISchema by name.
org.apache.hadoop.hive.metastore.api.SchemaVersion	getLatestSchemaVersion(org.apache.hadoop.hive.metastore.api.ISchemaName schemaName) Get the latest version of a schema.
String[]	getMasterKeys()
List<String>	getMaterializedViewsForRewriting(String catName, String dbName) Get list of materialized views in a database.
String	getMetastoreDbUuid() Gets the unique id of the backing datastore for the metadata
String	getMetaStoreSchemaVersion()
org.apache.hadoop.hive.metastore.api.NotificationEventResponse	getNextNotification(org.apache.hadoop.hive.metastore.api.NotificationEventRequest rqst) Get the next notification event.
org.apache.hadoop.hive.metastore.api.NotificationEventsCountResponse	getNotificationEventsCount(org.apache.hadoop.hive.metastore.api.NotificationEventsCountRequest rqst) Get the number of events corresponding to given database with fromEventId.
List<org.apache.hadoop.hive.metastore.api.SQLNotNullConstraint>	getNotNullConstraints(String catName, String db_name, String tbl_name) Get not null constraints on a table.
int	getNumPartitionsByExpr(String catName, String dbName, String tblName, byte[] expr) Get the number of partitions that match an already parsed expression.
int	getNumPartitionsByFilter(String catName, String dbName, String tblName, String filter) Get the number of partitions that match a provided SQL filter.
org.apache.hadoop.hive.metastore.api.Partition	getPartition(String catName, String dbName, String tableName, List<String> part_vals) Get a partition.
List<MetaStoreUtils.ColStatsObjWithSourceInfo>	getPartitionColStatsForDatabase(String catName, String dbName) Get column stats for all partitions of all tables in the database
Map<String,List<String>>	getPartitionColsWithStats(String catName, String dbName, String tableName)
List<org.apache.hadoop.hive.metastore.api.ColumnStatistics>	getPartitionColumnStatistics(String catName, String dbName, String tblName, List<String> partNames, List<String> colNames) Get statistics for a partition for a set of columns.
int	getPartitionCount() Gets total number of partitions.
org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet	getPartitionPrivilegeSet(String catName, String dbName, String tableName, String partition, String userName, List<String> groupNames) Get privileges for a partition for a user.
List<org.apache.hadoop.hive.metastore.api.Partition>	getPartitions(String catName, String dbName, String tableName, int max) Get some or all partitions for a table.
boolean	getPartitionsByExpr(String catName, String dbName, String tblName, byte[] expr, String defaultPartitionName, short maxParts, List<org.apache.hadoop.hive.metastore.api.Partition> result) Get partitions using an already parsed expression.
List<org.apache.hadoop.hive.metastore.api.Partition>	getPartitionsByFilter(String catName, String dbName, String tblName, String filter, short maxParts) Get partitions with a filter.
List<org.apache.hadoop.hive.metastore.api.Partition>	getPartitionsByNames(String catName, String dbName, String tblName, List<String> partNames) Get partitions by name.
List<org.apache.hadoop.hive.metastore.api.Partition>	getPartitionsWithAuth(String catName, String dbName, String tblName, short maxParts, String userName, List<String> groupNames) Fetch some or all partitions for a table, along with privilege information for a particular user.
org.apache.hadoop.hive.metastore.api.Partition	getPartitionWithAuth(String catName, String dbName, String tblName, List<String> partVals, String user_name, List<String> group_names) Fetch a partition along with privilege information for a particular user.
List<org.apache.hadoop.hive.metastore.api.SQLPrimaryKey>	getPrimaryKeys(String catName, String db_name, String tbl_name) Get the primary associated with a table.
org.apache.hadoop.hive.metastore.api.WMFullResourcePlan	getResourcePlan(String name)
org.apache.hadoop.hive.metastore.api.Role	getRole(String roleName)
List<org.apache.hadoop.hive.metastore.api.RuntimeStat>	getRuntimeStats(int maxEntries, int maxCreateTime) Reads runtime statistic entries.
org.apache.hadoop.hive.metastore.api.SchemaVersion	getSchemaVersion(org.apache.hadoop.hive.metastore.api.SchemaVersionDescriptor version) Get a specific schema version.
List<org.apache.hadoop.hive.metastore.api.SchemaVersion>	getSchemaVersionsByColumns(String colName, String colNamespace, String type) Find all SchemaVersion objects that match a query.
org.apache.hadoop.hive.metastore.api.SerDeInfo	getSerDeInfo(String serDeName) Get serde information
org.apache.hadoop.hive.metastore.api.Table	getTable(String catalogName, String dbName, String tableName) Get a table object.
org.apache.hadoop.hive.metastore.api.ColumnStatistics	getTableColumnStatistics(String catName, 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.
int	getTableCount() Gets total number of tables.
List<org.apache.hadoop.hive.metastore.api.TableMeta>	getTableMeta(String catName, String dbNames, String tableNames, List<String> tableTypes)
List<MetaStoreUtils.FullTableName>	getTableNamesWithStats()
List<org.apache.hadoop.hive.metastore.api.Table>	getTableObjectsByName(String catName, String dbname, List<String> tableNames)
org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet	getTablePrivilegeSet(String catName, String dbName, String tableName, String userName, List<String> groupNames) Get privileges for a table for a user.
List<String>	getTables(String catName, String dbName, String pattern) Get table names that match a pattern.
List<String>	getTables(String catName, String dbName, String pattern, TableType tableType) Get table names that match a pattern.
String	getToken(String tokenIdentifier)
List<org.apache.hadoop.hive.metastore.api.WMTrigger>	getTriggersForResourcePlan(String resourcePlanName)
org.apache.hadoop.hive.metastore.api.Type	getType(String typeName)
List<org.apache.hadoop.hive.metastore.api.SQLUniqueConstraint>	getUniqueConstraints(String catName, String db_name, String tbl_name) Get unique constraints associated with a table.
org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet	getUserPrivilegeSet(String userName, List<String> groupNames)
boolean	grantPrivileges(org.apache.hadoop.hive.metastore.api.PrivilegeBag privileges)
boolean	grantRole(org.apache.hadoop.hive.metastore.api.Role role, String userName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType, String grantor, org.apache.hadoop.hive.metastore.api.PrincipalType grantorType, boolean grantOption)
boolean	isActiveTransaction()
boolean	isFileMetadataSupported()
boolean	isPartitionMarkedForEvent(String catName, String dbName, String tblName, Map<String,String> partName, org.apache.hadoop.hive.metastore.api.PartitionEventType evtType)
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listAllTableGrants(String principalName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType, String catName, String dbName, String tableName) For a given principal name and type, list the Table Grants
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listDBGrantsAll(String catName, String dbName) Find all the privileges for a given database.
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listGlobalGrantsAll()
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listPartitionColumnGrantsAll(String catName, String dbName, String tableName, String partitionName, String columnName) Find all of the privileges for a given column in a given partition.
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listPartitionGrantsAll(String catName, String dbName, String tableName, String partitionName) Find all of the privileges for a given partition.
List<String>	listPartitionNames(String catName, String db_name, String tbl_name, short max_parts) Get a partial or complete list of names for partitions of a table.
List<String>	listPartitionNamesPs(String catName, String db_name, String tbl_name, List<String> part_vals, short max_parts) Lists partition names that match a given partial specification
List<org.apache.hadoop.hive.metastore.api.Partition>	listPartitionsPsWithAuth(String catName, 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.
org.apache.hadoop.hive.metastore.api.PartitionValuesResponse	listPartitionValues(String catName, String db_name, String tbl_name, List<org.apache.hadoop.hive.metastore.api.FieldSchema> cols, boolean applyDistinct, String filter, boolean ascending, List<org.apache.hadoop.hive.metastore.api.FieldSchema> order, long maxParts) Get a list of partition values as one big struct.
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listPrincipalDBGrants(String principalName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType, String catName, String dbName) For a given principal name and type, list the DB Grants
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listPrincipalDBGrantsAll(String principalName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType) List all DB grants for a given principal.
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listPrincipalGlobalGrants(String principalName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType)
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listPrincipalPartitionColumnGrants(String principalName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType, String catName, String dbName, String tableName, List<String> partValues, String partName, String columnName) For a given principal name and type, list the Table Grants
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listPrincipalPartitionColumnGrantsAll(String principalName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType) List all Partition column grants for a given principal
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listPrincipalPartitionGrants(String principalName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType, String catName, String dbName, String tableName, List<String> partValues, String partName) For a given principal name and type, list the Table Grants
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listPrincipalPartitionGrantsAll(String principalName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType) List all Partition grants for a given principal
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listPrincipalTableColumnGrants(String principalName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType, String catName, String dbName, String tableName, String columnName) For a given principal name and type, list the Table Grants
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listPrincipalTableColumnGrantsAll(String principalName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType) List all Table column grants for a given principal
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listPrincipalTableGrantsAll(String principalName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType) List all Table grants for a given principal
List<org.apache.hadoop.hive.metastore.api.RolePrincipalGrant>	listRoleMembers(String roleName) Get the role to principal grant mapping for given role
List<String>	listRoleNames()
List<org.apache.hadoop.hive.metastore.api.Role>	listRoles(String principalName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType)
List<org.apache.hadoop.hive.metastore.api.RolePrincipalGrant>	listRolesWithGrants(String principalName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType)
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listTableColumnGrantsAll(String catName, String dbName, String tableName, String columnName) Find all of the privileges for a given column in a given table.
List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>	listTableGrantsAll(String catName, String dbName, String tableName) Find all of the privileges for a given table
List<String>	listTableNamesByFilter(String catName, String dbName, String filter, short max_tables) Gets a list of tables based on a filter string and filter type.
org.apache.hadoop.hive.metastore.api.Table	markPartitionForEvent(String catName, String dbName, String tblName, Map<String,String> partVals, org.apache.hadoop.hive.metastore.api.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
void	putFileMetadata(List<Long> fileIds, List<ByteBuffer> metadata, org.apache.hadoop.hive.metastore.api.FileMetadataExprType type)
boolean	refreshPrivileges(org.apache.hadoop.hive.metastore.api.HiveObjectRef objToRefresh, String authorizer, org.apache.hadoop.hive.metastore.api.PrivilegeBag grantPrivileges)
boolean	removeMasterKey(Integer keySeq)
boolean	removeRole(String roleName)
boolean	removeToken(String tokenIdentifier)
boolean	revokePrivileges(org.apache.hadoop.hive.metastore.api.PrivilegeBag privileges, boolean grantOption)
boolean	revokeRole(org.apache.hadoop.hive.metastore.api.Role role, String userName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType, boolean grantOption)
void	rollbackTransaction() Rolls back the current transaction if it is active
void	setMetaStoreSchemaVersion(String version, String comment)
void	shutdown()
void	updateCreationMetadata(String catName, String dbname, String tablename, org.apache.hadoop.hive.metastore.api.CreationMetadata cm) Update creation metadata for a materialized view.
void	updateMasterKey(Integer seqNo, String key)
boolean	updatePartitionColumnStatistics(org.apache.hadoop.hive.metastore.api.ColumnStatistics statsObj, List<String> partVals) Persists the given column statistics object to the metastore
boolean	updateTableColumnStatistics(org.apache.hadoop.hive.metastore.api.ColumnStatistics colStats) Persists the given column statistics object to the metastore
org.apache.hadoop.hive.metastore.api.WMValidateResourcePlanResponse	validateResourcePlan(String name)
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

isActiveTransaction

boolean isActiveTransaction()

rollbackTransaction

void rollbackTransaction()

Rolls back the current transaction if it is active

createCatalog

void createCatalog(org.apache.hadoop.hive.metastore.api.Catalog cat)
            throws org.apache.hadoop.hive.metastore.api.MetaException

Create a new catalog.

Parameters:

cat - Catalog to create.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - if something goes wrong, usually in storing it to the database.

alterCatalog

void alterCatalog(String catName,
                  org.apache.hadoop.hive.metastore.api.Catalog cat)
           throws org.apache.hadoop.hive.metastore.api.MetaException,
                  org.apache.hadoop.hive.metastore.api.InvalidOperationException

Alter an existing catalog. Only description and location can be changed, and the change of location is for internal use only.

Parameters:

catName - name of the catalog to alter.

cat - new version of the catalog.

Throws:

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

org.apache.hadoop.hive.metastore.api.InvalidOperationException - attempt to change something about the catalog that is not changeable, like the name.

getCatalog

org.apache.hadoop.hive.metastore.api.Catalog getCatalog(String catalogName)
                                                 throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                        org.apache.hadoop.hive.metastore.api.MetaException

Get a catalog.

Parameters:

catalogName - name of the catalog.

Returns:

The catalog.

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no catalog of this name exists.

org.apache.hadoop.hive.metastore.api.MetaException - if something goes wrong, usually in reading it from the database.

getCatalogs

List<String> getCatalogs()
                  throws org.apache.hadoop.hive.metastore.api.MetaException

Get all the catalogs.

Returns:

list of names of all catalogs in the system

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - if something goes wrong, usually in reading from the database.

dropCatalog

void dropCatalog(String catalogName)
          throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                 org.apache.hadoop.hive.metastore.api.MetaException

Drop a catalog. The catalog must be empty.

Parameters:

catalogName - name of the catalog to drop.

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no catalog of this name exists.

org.apache.hadoop.hive.metastore.api.MetaException - could mean the catalog isn't empty, could mean general database error.

createDatabase

void createDatabase(org.apache.hadoop.hive.metastore.api.Database db)
             throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                    org.apache.hadoop.hive.metastore.api.MetaException

Create a database.

Parameters:

db - database to create.

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - not sure it actually ever throws this.

org.apache.hadoop.hive.metastore.api.MetaException - if something goes wrong, usually in writing it to the database.

getDatabase

org.apache.hadoop.hive.metastore.api.Database getDatabase(String catalogName,
                                                          String name)
                                                   throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Get a database.

Parameters:

catalogName - catalog the database is in.

name - name of the database.

Returns:

the database.

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - if no such database exists.

dropDatabase

boolean dropDatabase(String catalogName,
                     String dbname)
              throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                     org.apache.hadoop.hive.metastore.api.MetaException

Drop a database.

Parameters:

catalogName - catalog the database is in.

dbname - name of the database.

Returns:

true if the database was dropped, pretty much always returns this if it returns.

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no database in this catalog of this name to drop

org.apache.hadoop.hive.metastore.api.MetaException - something went wrong, usually with the database.

alterDatabase

boolean alterDatabase(String catalogName,
                      String dbname,
                      org.apache.hadoop.hive.metastore.api.Database db)
               throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                      org.apache.hadoop.hive.metastore.api.MetaException

Alter a database.

Parameters:

catalogName - name of the catalog the database is in.

dbname - name of the database to alter

db - new version of the database. This should be complete as it will fully replace the existing db object.

Returns:

true if the change succeeds, could fail due to db constraint violations.

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no database of this name exists to alter.

org.apache.hadoop.hive.metastore.api.MetaException - something went wrong, usually with the database.

getDatabases

List<String> getDatabases(String catalogName,
                          String pattern)
                   throws org.apache.hadoop.hive.metastore.api.MetaException

Get all database in a catalog having names that match a pattern.

Parameters:

catalogName - name of the catalog to search for databases in

pattern - pattern names should match

Returns:

list of matching database names.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - something went wrong, usually with the database.

getAllDatabases

List<String> getAllDatabases(String catalogName)
                      throws org.apache.hadoop.hive.metastore.api.MetaException

Get names of all the databases in a catalog.

Parameters:

catalogName - name of the catalog to search for databases in

Returns:

list of names of all databases in the catalog

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - something went wrong, usually with the database.

createType

boolean createType(org.apache.hadoop.hive.metastore.api.Type type)

getType

org.apache.hadoop.hive.metastore.api.Type getType(String typeName)

dropType

boolean dropType(String typeName)

createTable

void createTable(org.apache.hadoop.hive.metastore.api.Table tbl)
          throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                 org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

dropTable

boolean dropTable(String catalogName,
                  String dbName,
                  String tableName)
           throws org.apache.hadoop.hive.metastore.api.MetaException,
                  org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                  org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                  org.apache.hadoop.hive.metastore.api.InvalidInputException

Drop a table.

Parameters:

catalogName - catalog the table is in

dbName - database the table is in

tableName - table name

Returns:

true if the table was dropped

Throws:

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

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - No table of this name

org.apache.hadoop.hive.metastore.api.InvalidObjectException - Don't think this is ever actually thrown

org.apache.hadoop.hive.metastore.api.InvalidInputException - Don't think this is ever actually thrown

getTable

org.apache.hadoop.hive.metastore.api.Table getTable(String catalogName,
                                                    String dbName,
                                                    String tableName)
                                             throws org.apache.hadoop.hive.metastore.api.MetaException

Get a table object.

Parameters:

catalogName - catalog the table is in.

dbName - database the table is in.

tableName - table name.

Returns:

table object, or null if no such table exists (wow it would be nice if we either consistently returned null or consistently threw NoSuchObjectException).

Throws:

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

addPartition

boolean addPartition(org.apache.hadoop.hive.metastore.api.Partition part)
              throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                     org.apache.hadoop.hive.metastore.api.MetaException

Add a partition.

Parameters:

part - partition to add

Returns:

true if the partition was successfully added.

Throws:

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

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

addPartitions

boolean addPartitions(String catName,
                      String dbName,
                      String tblName,
                      List<org.apache.hadoop.hive.metastore.api.Partition> parts)
               throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                      org.apache.hadoop.hive.metastore.api.MetaException

Add a list of partitions to a table.

Parameters:

catName - catalog name.

dbName - database name.

tblName - table name.

parts - list of partitions to be added.

Returns:

true if the operation succeeded.

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - never throws this AFAICT

org.apache.hadoop.hive.metastore.api.MetaException - the partitions don't belong to the indicated table or error writing to the RDBMS.

addPartitions

boolean addPartitions(String catName,
                      String dbName,
                      String tblName,
                      PartitionSpecProxy partitionSpec,
                      boolean ifNotExists)
               throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                      org.apache.hadoop.hive.metastore.api.MetaException

Add a list of partitions to a table.

Parameters:

catName - catalog name.

dbName - database name.

tblName - table name.

partitionSpec - specification for the partition

ifNotExists - whether it is in an error if the partition already exists. If true, then it is not an error if the partition exists, if false, it is.

Returns:

whether the partition was created.

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - The passed in partition spec or table specification is invalid.

org.apache.hadoop.hive.metastore.api.MetaException - error writing to RDBMS.

getPartition

org.apache.hadoop.hive.metastore.api.Partition getPartition(String catName,
                                                            String dbName,
                                                            String tableName,
                                                            List<String> part_vals)
                                                     throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                            org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Get a partition.

Parameters:

catName - catalog name.

dbName - database name.

tableName - table name.

part_vals - partition values for this table.

Returns:

the partition.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - error reading from RDBMS.

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no partition matching this specification exists.

doesPartitionExist

boolean doesPartitionExist(String catName,
                           String dbName,
                           String tableName,
                           List<String> part_vals)
                    throws org.apache.hadoop.hive.metastore.api.MetaException,
                           org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Check whether a partition exists.

Parameters:

catName - catalog name.

dbName - database name.

tableName - table name.

part_vals - list of partition values.

Returns:

true if the partition exists, false otherwise.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - failure reading RDBMS

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - this is never thrown.

dropPartition

boolean dropPartition(String catName,
                      String dbName,
                      String tableName,
                      List<String> part_vals)
               throws org.apache.hadoop.hive.metastore.api.MetaException,
                      org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                      org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                      org.apache.hadoop.hive.metastore.api.InvalidInputException

Drop a partition.

Parameters:

catName - catalog name.

dbName - database name.

tableName - table name.

part_vals - list of partition values.

Returns:

true if the partition was dropped.

Throws:

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

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no partition matching this description exists

org.apache.hadoop.hive.metastore.api.InvalidObjectException - error dropping the statistics for the partition

org.apache.hadoop.hive.metastore.api.InvalidInputException - error dropping the statistics for the partition

getPartitions

List<org.apache.hadoop.hive.metastore.api.Partition> getPartitions(String catName,
                                                                   String dbName,
                                                                   String tableName,
                                                                   int max)
                                                            throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                   org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Get some or all partitions for a table.

Parameters:

catName - catalog name.

dbName - database name.

tableName - table name

max - maximum number of partitions, or -1 to get all partitions.

Returns:

list of partitions

Throws:

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

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

alterTable

void alterTable(String catName,
                String dbname,
                String name,
                org.apache.hadoop.hive.metastore.api.Table newTable)
         throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                org.apache.hadoop.hive.metastore.api.MetaException

Alter a table.

Parameters:

catName - catalog the table is in.

dbname - database the table is in.

name - name of the table.

newTable - New table object. Which parts of the table can be altered are implementation specific.

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - The new table object is invalid.

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

updateCreationMetadata

void updateCreationMetadata(String catName,
                            String dbname,
                            String tablename,
                            org.apache.hadoop.hive.metastore.api.CreationMetadata cm)
                     throws org.apache.hadoop.hive.metastore.api.MetaException

Update creation metadata for a materialized view.

Parameters:

catName - catalog name.

dbname - database name.

tablename - table name.

cm - new creation metadata

Throws:

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

getTables

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

Get table names that match a pattern.

Parameters:

catName - catalog to search in

dbName - database to search in

pattern - pattern to match

Returns:

list of table names, if any

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - failure in querying the RDBMS

getTables

List<String> getTables(String catName,
                       String dbName,
                       String pattern,
                       TableType tableType)
                throws org.apache.hadoop.hive.metastore.api.MetaException

Get table names that match a pattern.

Parameters:

catName - catalog to search in

dbName - database to search in

pattern - pattern to match

tableType - type of table to look for

Returns:

list of table names, if any

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - failure in querying the RDBMS

getMaterializedViewsForRewriting

List<String> getMaterializedViewsForRewriting(String catName,
                                              String dbName)
                                       throws org.apache.hadoop.hive.metastore.api.MetaException,
                                              org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Get list of materialized views in a database.

Parameters:

catName - catalog name

dbName - database name

Returns:

names of all materialized views in the database

Throws:

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

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

getTableMeta

List<org.apache.hadoop.hive.metastore.api.TableMeta> getTableMeta(String catName,
                                                                  String dbNames,
                                                                  String tableNames,
                                                                  List<String> tableTypes)
                                                           throws org.apache.hadoop.hive.metastore.api.MetaException

Parameters:

catName - catalog name to search in. Search must be confined to one catalog.

dbNames - databases to search in.

tableNames - names of tables to select.

tableTypes - types of tables to look for.

Returns:

list of matching table meta information.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - failure in querying the RDBMS.

getTableObjectsByName

List<org.apache.hadoop.hive.metastore.api.Table> getTableObjectsByName(String catName,
                                                                       String dbname,
                                                                       List<String> tableNames)
                                                                throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                       org.apache.hadoop.hive.metastore.api.UnknownDBException

Parameters:

catName - catalog name

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:

org.apache.hadoop.hive.metastore.api.MetaException - failure in querying the RDBMS.

org.apache.hadoop.hive.metastore.api.UnknownDBException

getAllTables

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

Get all tables in a database.

Parameters:

catName - catalog name.

dbName - database name.

Returns:

list of table names

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - failure in querying the RDBMS.

listTableNamesByFilter

List<String> listTableNamesByFilter(String catName,
                                    String dbName,
                                    String filter,
                                    short max_tables)
                             throws org.apache.hadoop.hive.metastore.api.MetaException,
                                    org.apache.hadoop.hive.metastore.api.UnknownDBException

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

Parameters:

catName - catalog name

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:

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

org.apache.hadoop.hive.metastore.api.UnknownDBException

listPartitionNames

List<String> listPartitionNames(String catName,
                                String db_name,
                                String tbl_name,
                                short max_parts)
                         throws org.apache.hadoop.hive.metastore.api.MetaException

Get a partial or complete list of names for partitions of a table.

Parameters:

catName - catalog name.

db_name - database name.

tbl_name - table name.

max_parts - maximum number of partitions to retrieve, -1 for all.

Returns:

list of partition names.

Throws:

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

listPartitionValues

org.apache.hadoop.hive.metastore.api.PartitionValuesResponse listPartitionValues(String catName,
                                                                                 String db_name,
                                                                                 String tbl_name,
                                                                                 List<org.apache.hadoop.hive.metastore.api.FieldSchema> cols,
                                                                                 boolean applyDistinct,
                                                                                 String filter,
                                                                                 boolean ascending,
                                                                                 List<org.apache.hadoop.hive.metastore.api.FieldSchema> order,
                                                                                 long maxParts)
                                                                          throws org.apache.hadoop.hive.metastore.api.MetaException

Get a list of partition values as one big struct.

Parameters:

catName - catalog name.

db_name - database name.

tbl_name - table name.

cols - partition key columns

applyDistinct - whether to apply distinct to the list

filter - filter to apply to the partition names

ascending - whether to put in ascending order

order - whether to order

maxParts - maximum number of parts to return, or -1 for all

Returns:

struct with all of the partition value information

Throws:

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

alterPartition

void alterPartition(String catName,
                    String db_name,
                    String tbl_name,
                    List<String> part_vals,
                    org.apache.hadoop.hive.metastore.api.Partition new_part)
             throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                    org.apache.hadoop.hive.metastore.api.MetaException

Alter a partition.

Parameters:

catName - catalog name.

db_name - database name.

tbl_name - table name.

part_vals - partition values that describe the partition.

new_part - new partition object. This should be a complete copy of the old with changes values, not just the parts to update.

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - No such partition.

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

alterPartitions

void alterPartitions(String catName,
                     String db_name,
                     String tbl_name,
                     List<List<String>> part_vals_list,
                     List<org.apache.hadoop.hive.metastore.api.Partition> new_parts)
              throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                     org.apache.hadoop.hive.metastore.api.MetaException

Alter a set of partitions.

Parameters:

catName - catalog name.

db_name - database name.

tbl_name - table name.

part_vals_list - list of list of partition values. Each outer list describes one partition (with its list of partition values).

new_parts - list of new partitions. The order must match the old partitions described in part_vals_list. Each of these should be a complete copy of the new partition, not just the pieces to update.

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - One of the indicated partitions does not exist.

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

getPartitionsByFilter

List<org.apache.hadoop.hive.metastore.api.Partition> getPartitionsByFilter(String catName,
                                                                           String dbName,
                                                                           String tblName,
                                                                           String filter,
                                                                           short maxParts)
                                                                    throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                           org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Get partitions with a filter. This is a portion of the SQL where clause.

Parameters:

catName - catalog name

dbName - database name

tblName - table name

filter - SQL where clause filter

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

Returns:

list of partition objects matching the criteria

Throws:

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

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

getPartitionsByExpr

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

Get partitions using an already parsed expression.

Parameters:

catName - catalog name.

dbName - database name

tblName - table name

expr - an already parsed Hive expression

defaultPartitionName - default name of a partition

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

result - list to place resulting partitions in

Returns:

true if the result contains unknown partitions.

Throws:

org.apache.thrift.TException - error executing the expression

getNumPartitionsByFilter

int getNumPartitionsByFilter(String catName,
                             String dbName,
                             String tblName,
                             String filter)
                      throws org.apache.hadoop.hive.metastore.api.MetaException,
                             org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Get the number of partitions that match a provided SQL filter.

Parameters:

catName - catalog name.

dbName - database name.

tblName - table name.

filter - filter from Hive's SQL where clause

Returns:

number of matching partitions.

Throws:

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

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

getNumPartitionsByExpr

int getNumPartitionsByExpr(String catName,
                           String dbName,
                           String tblName,
                           byte[] expr)
                    throws org.apache.hadoop.hive.metastore.api.MetaException,
                           org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Get the number of partitions that match an already parsed expression.

Parameters:

catName - catalog name.

dbName - database name.

tblName - table name.

expr - an already parsed Hive expression

Returns:

number of matching partitions.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - error accessing the RDBMS or working with the expression.

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

getPartitionsByNames

List<org.apache.hadoop.hive.metastore.api.Partition> getPartitionsByNames(String catName,
                                                                          String dbName,
                                                                          String tblName,
                                                                          List<String> partNames)
                                                                   throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                          org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Get partitions by name.

Parameters:

catName - catalog name.

dbName - database name.

tblName - table name.

partNames - list of partition names. These are names not values, so they will include both the key and the value.

Returns:

list of matching partitions

Throws:

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

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

markPartitionForEvent

org.apache.hadoop.hive.metastore.api.Table markPartitionForEvent(String catName,
                                                                 String dbName,
                                                                 String tblName,
                                                                 Map<String,String> partVals,
                                                                 org.apache.hadoop.hive.metastore.api.PartitionEventType evtType)
                                                          throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                 org.apache.hadoop.hive.metastore.api.UnknownTableException,
                                                                 org.apache.hadoop.hive.metastore.api.InvalidPartitionException,
                                                                 org.apache.hadoop.hive.metastore.api.UnknownPartitionException

Throws:

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

org.apache.hadoop.hive.metastore.api.UnknownTableException

org.apache.hadoop.hive.metastore.api.InvalidPartitionException

org.apache.hadoop.hive.metastore.api.UnknownPartitionException

isPartitionMarkedForEvent

boolean isPartitionMarkedForEvent(String catName,
                                  String dbName,
                                  String tblName,
                                  Map<String,String> partName,
                                  org.apache.hadoop.hive.metastore.api.PartitionEventType evtType)
                           throws org.apache.hadoop.hive.metastore.api.MetaException,
                                  org.apache.hadoop.hive.metastore.api.UnknownTableException,
                                  org.apache.hadoop.hive.metastore.api.InvalidPartitionException,
                                  org.apache.hadoop.hive.metastore.api.UnknownPartitionException

Throws:

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

org.apache.hadoop.hive.metastore.api.UnknownTableException

org.apache.hadoop.hive.metastore.api.InvalidPartitionException

org.apache.hadoop.hive.metastore.api.UnknownPartitionException

addRole

boolean addRole(String rowName,
                String ownerName)
         throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                org.apache.hadoop.hive.metastore.api.MetaException,
                org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:

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

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

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

removeRole

boolean removeRole(String roleName)
            throws org.apache.hadoop.hive.metastore.api.MetaException,
                   org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:

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

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

grantRole

boolean grantRole(org.apache.hadoop.hive.metastore.api.Role role,
                  String userName,
                  org.apache.hadoop.hive.metastore.api.PrincipalType principalType,
                  String grantor,
                  org.apache.hadoop.hive.metastore.api.PrincipalType grantorType,
                  boolean grantOption)
           throws org.apache.hadoop.hive.metastore.api.MetaException,
                  org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                  org.apache.hadoop.hive.metastore.api.InvalidObjectException

Throws:

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

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

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

revokeRole

boolean revokeRole(org.apache.hadoop.hive.metastore.api.Role role,
                   String userName,
                   org.apache.hadoop.hive.metastore.api.PrincipalType principalType,
                   boolean grantOption)
            throws org.apache.hadoop.hive.metastore.api.MetaException,
                   org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:

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

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

getUserPrivilegeSet

org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet getUserPrivilegeSet(String userName,
                                                                               List<String> groupNames)
                                                                        throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                                                               org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

getDBPrivilegeSet

org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet getDBPrivilegeSet(String catName,
                                                                             String dbName,
                                                                             String userName,
                                                                             List<String> groupNames)
                                                                      throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                                                             org.apache.hadoop.hive.metastore.api.MetaException

Get privileges for a database for a user.

Parameters:

catName - catalog name

dbName - database name

userName - user name

groupNames - list of groups the user is in

Returns:

privileges for that user on indicated database

Throws:

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

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

getTablePrivilegeSet

org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet getTablePrivilegeSet(String catName,
                                                                                String dbName,
                                                                                String tableName,
                                                                                String userName,
                                                                                List<String> groupNames)
                                                                         throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                                                                org.apache.hadoop.hive.metastore.api.MetaException

Get privileges for a table for a user.

Parameters:

catName - catalog name

dbName - database name

tableName - table name

userName - user name

groupNames - list of groups the user is in

Returns:

privileges for that user on indicated table

Throws:

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

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

getPartitionPrivilegeSet

org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet getPartitionPrivilegeSet(String catName,
                                                                                    String dbName,
                                                                                    String tableName,
                                                                                    String partition,
                                                                                    String userName,
                                                                                    List<String> groupNames)
                                                                             throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                                                                    org.apache.hadoop.hive.metastore.api.MetaException

Get privileges for a partition for a user.

Parameters:

catName - catalog name

dbName - database name

tableName - table name

partition - partition name

userName - user name

groupNames - list of groups the user is in

Returns:

privileges for that user on indicated partition

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - no such partition

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

getColumnPrivilegeSet

org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet getColumnPrivilegeSet(String catName,
                                                                                 String dbName,
                                                                                 String tableName,
                                                                                 String partitionName,
                                                                                 String columnName,
                                                                                 String userName,
                                                                                 List<String> groupNames)
                                                                          throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                                                                 org.apache.hadoop.hive.metastore.api.MetaException

Get privileges for a column in a table or partition for a user.

Parameters:

catName - catalog name

dbName - database name

tableName - table name

partitionName - partition name, or null for table level column permissions

columnName - column name

userName - user name

groupNames - list of groups the user is in

Returns:

privileges for that user on indicated column in the table or partition

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - no such table, partition, or column

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

listPrincipalGlobalGrants

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listPrincipalGlobalGrants(String principalName,
                                                                                         org.apache.hadoop.hive.metastore.api.PrincipalType principalType)

listPrincipalDBGrants

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listPrincipalDBGrants(String principalName,
                                                                                     org.apache.hadoop.hive.metastore.api.PrincipalType principalType,
                                                                                     String catName,
                                                                                     String dbName)

For a given principal name and type, list the DB Grants

Parameters:

principalName - principal name

principalType - type

catName - catalog name

dbName - database name

Returns:

list of privileges for that principal on the specified database.

listAllTableGrants

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listAllTableGrants(String principalName,
                                                                                  org.apache.hadoop.hive.metastore.api.PrincipalType principalType,
                                                                                  String catName,
                                                                                  String dbName,
                                                                                  String tableName)

For a given principal name and type, list the Table Grants

Parameters:

principalName - principal name

principalType - type

catName - catalog name

dbName - database name

tableName - table name

Returns:

list of privileges for that principal on the specified database.

listPrincipalPartitionGrants

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listPrincipalPartitionGrants(String principalName,
                                                                                            org.apache.hadoop.hive.metastore.api.PrincipalType principalType,
                                                                                            String catName,
                                                                                            String dbName,
                                                                                            String tableName,
                                                                                            List<String> partValues,
                                                                                            String partName)

For a given principal name and type, list the Table Grants

Parameters:

principalName - principal name

principalType - type

catName - catalog name

dbName - database name

tableName - table name

partName - partition name (not value)

Returns:

list of privileges for that principal on the specified database.

listPrincipalTableColumnGrants

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listPrincipalTableColumnGrants(String principalName,
                                                                                              org.apache.hadoop.hive.metastore.api.PrincipalType principalType,
                                                                                              String catName,
                                                                                              String dbName,
                                                                                              String tableName,
                                                                                              String columnName)

For a given principal name and type, list the Table Grants

Parameters:

principalName - principal name

principalType - type

catName - catalog name

dbName - database name

tableName - table name

columnName - column name

Returns:

list of privileges for that principal on the specified database.

listPrincipalPartitionColumnGrants

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listPrincipalPartitionColumnGrants(String principalName,
                                                                                                  org.apache.hadoop.hive.metastore.api.PrincipalType principalType,
                                                                                                  String catName,
                                                                                                  String dbName,
                                                                                                  String tableName,
                                                                                                  List<String> partValues,
                                                                                                  String partName,
                                                                                                  String columnName)

For a given principal name and type, list the Table Grants

Parameters:

principalName - principal name

principalType - type

catName - catalog name

dbName - database name

tableName - table name

partName - partition name (not value)

columnName - column name

Returns:

list of privileges for that principal on the specified database.

grantPrivileges

boolean grantPrivileges(org.apache.hadoop.hive.metastore.api.PrivilegeBag privileges)
                 throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                        org.apache.hadoop.hive.metastore.api.MetaException,
                        org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:

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

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

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

revokePrivileges

boolean revokePrivileges(org.apache.hadoop.hive.metastore.api.PrivilegeBag privileges,
                         boolean grantOption)
                  throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                         org.apache.hadoop.hive.metastore.api.MetaException,
                         org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:

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

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

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

refreshPrivileges

boolean refreshPrivileges(org.apache.hadoop.hive.metastore.api.HiveObjectRef objToRefresh,
                          String authorizer,
                          org.apache.hadoop.hive.metastore.api.PrivilegeBag grantPrivileges)
                   throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                          org.apache.hadoop.hive.metastore.api.MetaException,
                          org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:

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

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

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

getRole

org.apache.hadoop.hive.metastore.api.Role getRole(String roleName)
                                           throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:

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

listRoleNames

List<String> listRoleNames()

listRoles

List<org.apache.hadoop.hive.metastore.api.Role> listRoles(String principalName,
                                                          org.apache.hadoop.hive.metastore.api.PrincipalType principalType)

listRolesWithGrants

List<org.apache.hadoop.hive.metastore.api.RolePrincipalGrant> listRolesWithGrants(String principalName,
                                                                                  org.apache.hadoop.hive.metastore.api.PrincipalType principalType)

listRoleMembers

List<org.apache.hadoop.hive.metastore.api.RolePrincipalGrant> listRoleMembers(String roleName)

Get the role to principal grant mapping for given role

Parameters:

roleName -

Returns:

getPartitionWithAuth

org.apache.hadoop.hive.metastore.api.Partition getPartitionWithAuth(String catName,
                                                                    String dbName,
                                                                    String tblName,
                                                                    List<String> partVals,
                                                                    String user_name,
                                                                    List<String> group_names)
                                                             throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                    org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                                    org.apache.hadoop.hive.metastore.api.InvalidObjectException

Fetch a partition along with privilege information for a particular user.

Parameters:

catName - catalog name.

dbName - database name.

tblName - table name.

partVals - partition values

user_name - user to get privilege information for.

group_names - groups to get privilege information for.

Returns:

a partition

Throws:

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

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no such partition exists

org.apache.hadoop.hive.metastore.api.InvalidObjectException - error fetching privilege information

getPartitionsWithAuth

List<org.apache.hadoop.hive.metastore.api.Partition> getPartitionsWithAuth(String catName,
                                                                           String dbName,
                                                                           String tblName,
                                                                           short maxParts,
                                                                           String userName,
                                                                           List<String> groupNames)
                                                                    throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                           org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                                           org.apache.hadoop.hive.metastore.api.InvalidObjectException

Fetch some or all partitions for a table, along with privilege information for a particular user.

Parameters:

catName - catalog name.

dbName - database name.

tblName - table name.

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

userName - user to get privilege information for.

groupNames - groups to get privilege information for.

Returns:

list of partitions.

Throws:

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

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

org.apache.hadoop.hive.metastore.api.InvalidObjectException - error fetching privilege information.

listPartitionNamesPs

List<String> listPartitionNamesPs(String catName,
                                  String db_name,
                                  String tbl_name,
                                  List<String> part_vals,
                                  short max_parts)
                           throws org.apache.hadoop.hive.metastore.api.MetaException,
                                  org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Lists partition names that match a given partial specification

Parameters:

catName - catalog name.

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:

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

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

listPartitionsPsWithAuth

List<org.apache.hadoop.hive.metastore.api.Partition> listPartitionsPsWithAuth(String catName,
                                                                              String db_name,
                                                                              String tbl_name,
                                                                              List<String> part_vals,
                                                                              short max_parts,
                                                                              String userName,
                                                                              List<String> groupNames)
                                                                       throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                              org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                                                              org.apache.hadoop.hive.metastore.api.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:

catName - catalog name.

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:

org.apache.hadoop.hive.metastore.api.MetaException - error access RDBMS

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

org.apache.hadoop.hive.metastore.api.InvalidObjectException - error access privilege information

updateTableColumnStatistics

boolean updateTableColumnStatistics(org.apache.hadoop.hive.metastore.api.ColumnStatistics colStats)
                             throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                    org.apache.hadoop.hive.metastore.api.MetaException,
                                    org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                    org.apache.hadoop.hive.metastore.api.InvalidInputException

Persists the given column statistics object to the metastore

Parameters:

colStats - object to persist

Returns:

Boolean indicating the outcome of the operation

Throws:

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

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

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

org.apache.hadoop.hive.metastore.api.InvalidInputException - unable to record the stats for the table

updatePartitionColumnStatistics

boolean updatePartitionColumnStatistics(org.apache.hadoop.hive.metastore.api.ColumnStatistics statsObj,
                                        List<String> partVals)
                                 throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                        org.apache.hadoop.hive.metastore.api.MetaException,
                                        org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                        org.apache.hadoop.hive.metastore.api.InvalidInputException

Persists the given column statistics object to the metastore

Parameters:

statsObj - object to persist

partVals - partition values to persist the stats for

Returns:

Boolean indicating the outcome of the operation

Throws:

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

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

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

org.apache.hadoop.hive.metastore.api.InvalidInputException - unable to record the stats for the table

getTableColumnStatistics

org.apache.hadoop.hive.metastore.api.ColumnStatistics getTableColumnStatistics(String catName,
                                                                               String dbName,
                                                                               String tableName,
                                                                               List<String> colName)
                                                                        throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                               org.apache.hadoop.hive.metastore.api.NoSuchObjectException

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

Parameters:

catName - catalog name.

dbName - name of the database, defaults to current database

tableName - name of the table

colName - names of the columns for which statistics is requested

Returns:

Relevant column statistics for the column for the given table

Throws:

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

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

getPartitionColumnStatistics

List<org.apache.hadoop.hive.metastore.api.ColumnStatistics> getPartitionColumnStatistics(String catName,
                                                                                         String dbName,
                                                                                         String tblName,
                                                                                         List<String> partNames,
                                                                                         List<String> colNames)
                                                                                  throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                                         org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Get statistics for a partition for a set of columns.

Parameters:

catName - catalog name.

dbName - database name.

tblName - table name.

partNames - list of partition names. These are names so must be key1=val1[/key2=val2...]

colNames - list of columns to get stats for

Returns:

list of statistics objects

Throws:

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

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

deletePartitionColumnStatistics

boolean deletePartitionColumnStatistics(String catName,
                                        String dbName,
                                        String tableName,
                                        String partName,
                                        List<String> partVals,
                                        String colName)
                                 throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                        org.apache.hadoop.hive.metastore.api.MetaException,
                                        org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                        org.apache.hadoop.hive.metastore.api.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:

catName - catalog name.

dbName - database name.

tableName - table name.

partName - partition name.

partVals - partition values.

colName - column name.

Returns:

Boolean indicating the outcome of the operation

Throws:

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

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

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

org.apache.hadoop.hive.metastore.api.InvalidInputException - bad input, such as null table or database name.

deleteTableColumnStatistics

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

Delete statistics for a single column or all columns in a table.

Parameters:

catName - catalog name

dbName - database name

tableName - table name

colName - column name. Null to delete stats for all columns in the table.

Returns:

true if the statistics were deleted.

Throws:

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

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

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

org.apache.hadoop.hive.metastore.api.InvalidInputException - bad inputs, such as null table name.

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 org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

updateMasterKey

void updateMasterKey(Integer seqNo,
                     String key)
              throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                     org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

removeMasterKey

boolean removeMasterKey(Integer keySeq)

getMasterKeys

String[] getMasterKeys()

verifySchema

void verifySchema()
           throws org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

getMetaStoreSchemaVersion

String getMetaStoreSchemaVersion()
                          throws org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

setMetaStoreSchemaVersion

void setMetaStoreSchemaVersion(String version,
                               String comment)
                        throws org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

dropPartitions

void dropPartitions(String catName,
                    String dbName,
                    String tblName,
                    List<String> partNames)
             throws org.apache.hadoop.hive.metastore.api.MetaException,
                    org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Drop a list of partitions.

Parameters:

catName - catalog name.

dbName - database name.

tblName - table name

partNames - list of partition names.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - error access RDBMS or storage.

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - One or more of the partitions does not exist.

listPrincipalDBGrantsAll

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listPrincipalDBGrantsAll(String principalName,
                                                                                        org.apache.hadoop.hive.metastore.api.PrincipalType principalType)

List all DB grants for a given principal.

Parameters:

principalName - principal name

principalType - type

Returns:

all DB grants for this principal

listPrincipalTableGrantsAll

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listPrincipalTableGrantsAll(String principalName,
                                                                                           org.apache.hadoop.hive.metastore.api.PrincipalType principalType)

List all Table grants for a given principal

Parameters:

principalName - principal name

principalType - type

Returns:

all Table grants for this principal

listPrincipalPartitionGrantsAll

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listPrincipalPartitionGrantsAll(String principalName,
                                                                                               org.apache.hadoop.hive.metastore.api.PrincipalType principalType)

List all Partition grants for a given principal

Parameters:

principalName - principal name

principalType - type

Returns:

all Partition grants for this principal

listPrincipalTableColumnGrantsAll

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listPrincipalTableColumnGrantsAll(String principalName,
                                                                                                 org.apache.hadoop.hive.metastore.api.PrincipalType principalType)

List all Table column grants for a given principal

Parameters:

principalName - principal name

principalType - type

Returns:

all Table column grants for this principal

listPrincipalPartitionColumnGrantsAll

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listPrincipalPartitionColumnGrantsAll(String principalName,
                                                                                                     org.apache.hadoop.hive.metastore.api.PrincipalType principalType)

List all Partition column grants for a given principal

Parameters:

principalName - principal name

principalType - type

Returns:

all Partition column grants for this principal

listGlobalGrantsAll

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listGlobalGrantsAll()

listDBGrantsAll

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listDBGrantsAll(String catName,
                                                                               String dbName)

Find all the privileges for a given database.

Parameters:

catName - catalog name

dbName - database name

Returns:

list of all privileges.

listPartitionColumnGrantsAll

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listPartitionColumnGrantsAll(String catName,
                                                                                            String dbName,
                                                                                            String tableName,
                                                                                            String partitionName,
                                                                                            String columnName)

Find all of the privileges for a given column in a given partition.

Parameters:

catName - catalog name

dbName - database name

tableName - table name

partitionName - partition name (not value)

columnName - column name

Returns:

all privileges on this column in this partition

listTableGrantsAll

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listTableGrantsAll(String catName,
                                                                                  String dbName,
                                                                                  String tableName)

Find all of the privileges for a given table

Parameters:

catName - catalog name

dbName - database name

tableName - table name

Returns:

all privileges on this table

listPartitionGrantsAll

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listPartitionGrantsAll(String catName,
                                                                                      String dbName,
                                                                                      String tableName,
                                                                                      String partitionName)

Find all of the privileges for a given partition.

Parameters:

catName - catalog name

dbName - database name

tableName - table name

partitionName - partition name (not value)

Returns:

all privileges on this partition

listTableColumnGrantsAll

List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> listTableColumnGrantsAll(String catName,
                                                                                        String dbName,
                                                                                        String tableName,
                                                                                        String columnName)

Find all of the privileges for a given column in a given table.

Parameters:

catName - catalog name

dbName - database name

tableName - table name

columnName - column name

Returns:

all privileges on this column in this table

createFunction

void createFunction(org.apache.hadoop.hive.metastore.api.Function func)
             throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                    org.apache.hadoop.hive.metastore.api.MetaException

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

Parameters:

func - function to create

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - incorrectly specified function

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

alterFunction

void alterFunction(String catName,
                   String dbName,
                   String funcName,
                   org.apache.hadoop.hive.metastore.api.Function newFunction)
            throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                   org.apache.hadoop.hive.metastore.api.MetaException

Alter function based on new function specs.

Parameters:

dbName - database name

funcName - function name

newFunction - new function specification

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - no such function, or incorrectly specified new function

org.apache.hadoop.hive.metastore.api.MetaException - incorrectly specified function

dropFunction

void dropFunction(String catName,
                  String dbName,
                  String funcName)
           throws org.apache.hadoop.hive.metastore.api.MetaException,
                  org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                  org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                  org.apache.hadoop.hive.metastore.api.InvalidInputException

Drop a function definition.

Parameters:

dbName - database name

funcName - function name

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - incorrectly specified function

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

org.apache.hadoop.hive.metastore.api.InvalidObjectException - not sure when this is thrown

org.apache.hadoop.hive.metastore.api.InvalidInputException - not sure when this is thrown

getFunction

org.apache.hadoop.hive.metastore.api.Function getFunction(String catName,
                                                          String dbName,
                                                          String funcName)
                                                   throws org.apache.hadoop.hive.metastore.api.MetaException

Retrieve function by name.

Parameters:

dbName - database name

funcName - function name

Returns:

the function

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - incorrectly specified function

getAllFunctions

List<org.apache.hadoop.hive.metastore.api.Function> getAllFunctions(String catName)
                                                             throws org.apache.hadoop.hive.metastore.api.MetaException

Retrieve all functions.

Returns:

all functions in a catalog

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - incorrectly specified function

getFunctions

List<String> getFunctions(String catName,
                          String dbName,
                          String pattern)
                   throws org.apache.hadoop.hive.metastore.api.MetaException

Retrieve list of function names based on name pattern.

Parameters:

dbName - database name

pattern - pattern to match

Returns:

functions that match the pattern

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - incorrectly specified function

get_aggr_stats_for

org.apache.hadoop.hive.metastore.api.AggrStats get_aggr_stats_for(String catName,
                                                                  String dbName,
                                                                  String tblName,
                                                                  List<String> partNames,
                                                                  List<String> colNames)
                                                           throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                  org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Get aggregated stats for a table or partition(s).

Parameters:

catName - catalog name.

dbName - database name.

tblName - table name.

partNames - list of partition names. These are the names of the partitions, not values.

colNames - list of column names

Returns:

aggregated stats

Throws:

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

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

getPartitionColStatsForDatabase

List<MetaStoreUtils.ColStatsObjWithSourceInfo> getPartitionColStatsForDatabase(String catName,
                                                                               String dbName)
                                                                        throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                               org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Get column stats for all partitions of all tables in the database

Parameters:

catName - catalog name

dbName - database name

Returns:

List of column stats objects for all partitions of all tables in the database

Throws:

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

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

getNextNotification

org.apache.hadoop.hive.metastore.api.NotificationEventResponse getNextNotification(org.apache.hadoop.hive.metastore.api.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(org.apache.hadoop.hive.metastore.api.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

org.apache.hadoop.hive.metastore.api.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:

getNotificationEventsCount

org.apache.hadoop.hive.metastore.api.NotificationEventsCountResponse getNotificationEventsCount(org.apache.hadoop.hive.metastore.api.NotificationEventsCountRequest rqst)

Get the number of events corresponding to given database with fromEventId. This is intended for use by the repl commands to track the progress of incremental dump.

Returns:

flushCache

void flushCache()

getFileMetadata

ByteBuffer[] getFileMetadata(List<Long> fileIds)
                      throws org.apache.hadoop.hive.metastore.api.MetaException

Parameters:

fileIds - List of file IDs from the filesystem.

Returns:

File metadata buffers from file metadata cache. The array is fileIds-sized, and the entries (or nulls, if metadata is not in cache) correspond to fileIds in the list

Throws:

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

putFileMetadata

void putFileMetadata(List<Long> fileIds,
                     List<ByteBuffer> metadata,
                     org.apache.hadoop.hive.metastore.api.FileMetadataExprType type)
              throws org.apache.hadoop.hive.metastore.api.MetaException

Parameters:

fileIds - List of file IDs from the filesystem.

metadata - Metadata buffers corresponding to fileIds in the list.

type - The type; determines the class that can do additiona processing for metadata.

Throws:

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

isFileMetadataSupported

boolean isFileMetadataSupported()

Returns:

Whether file metadata cache is supported by this implementation.

getFileMetadataByExpr

void getFileMetadataByExpr(List<Long> fileIds,
                           org.apache.hadoop.hive.metastore.api.FileMetadataExprType type,
                           byte[] expr,
                           ByteBuffer[] metadatas,
                           ByteBuffer[] exprResults,
                           boolean[] eliminated)
                    throws org.apache.hadoop.hive.metastore.api.MetaException

Gets file metadata from cache after applying a format-specific expression that can produce additional information based on file metadata and also filter the file list.

Parameters:

fileIds - List of file IDs from the filesystem.

expr - Format-specific serialized expression applicable to the files' metadatas.

type - Expression type; used to determine the class that handles the metadata.

metadatas - Output parameter; fileIds-sized array to receive the metadatas for corresponding files, if any.

exprResults - Output parameter; fileIds-sized array to receive the format-specific expression results for the corresponding files.

eliminated - Output parameter; fileIds-sized array to receive the indication of whether the corresponding files are entirely eliminated by the expression.

Throws:

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

getFileMetadataHandler

FileMetadataHandler getFileMetadataHandler(org.apache.hadoop.hive.metastore.api.FileMetadataExprType type)

Gets file metadata handler for the corresponding type.

getTableCount

@InterfaceStability.Evolving
int getTableCount()
                                        throws org.apache.hadoop.hive.metastore.api.MetaException

Gets total number of tables.

Throws:

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

getPartitionCount

@InterfaceStability.Evolving
int getPartitionCount()
                                            throws org.apache.hadoop.hive.metastore.api.MetaException

Gets total number of partitions.

Throws:

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

getDatabaseCount

@InterfaceStability.Evolving
int getDatabaseCount()
                                           throws org.apache.hadoop.hive.metastore.api.MetaException

Gets total number of databases.

Throws:

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

getPrimaryKeys

List<org.apache.hadoop.hive.metastore.api.SQLPrimaryKey> getPrimaryKeys(String catName,
                                                                        String db_name,
                                                                        String tbl_name)
                                                                 throws org.apache.hadoop.hive.metastore.api.MetaException

Get the primary associated with a table. Strangely enough each SQLPrimaryKey is actually a column in they key, not the key itself. Thus the list.

Parameters:

catName - catalog name

db_name - database name

tbl_name - table name

Returns:

list of primary key columns or an empty list if the table does not have a primary key

Throws:

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

getForeignKeys

List<org.apache.hadoop.hive.metastore.api.SQLForeignKey> getForeignKeys(String catName,
                                                                        String parent_db_name,
                                                                        String parent_tbl_name,
                                                                        String foreign_db_name,
                                                                        String foreign_tbl_name)
                                                                 throws org.apache.hadoop.hive.metastore.api.MetaException

Get the foreign keys for a table. All foreign keys for a particular table can be fetched by passing null for the last two arguments.

Parameters:

catName - catalog name.

parent_db_name - Database the table referred to is in. This can be null to match all databases.

parent_tbl_name - Table that is referred to. This can be null to match all tables.

foreign_db_name - Database the table with the foreign key is in.

foreign_tbl_name - Table with the foreign key.

Returns:

List of all matching foreign key columns. Note that if more than one foreign key matches the arguments the results here will be all mixed together into a single list.

Throws:

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

getUniqueConstraints

List<org.apache.hadoop.hive.metastore.api.SQLUniqueConstraint> getUniqueConstraints(String catName,
                                                                                    String db_name,
                                                                                    String tbl_name)
                                                                             throws org.apache.hadoop.hive.metastore.api.MetaException

Get unique constraints associated with a table.

Parameters:

catName - catalog name.

db_name - database name.

tbl_name - table name.

Returns:

list of unique constraints

Throws:

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

getNotNullConstraints

List<org.apache.hadoop.hive.metastore.api.SQLNotNullConstraint> getNotNullConstraints(String catName,
                                                                                      String db_name,
                                                                                      String tbl_name)
                                                                               throws org.apache.hadoop.hive.metastore.api.MetaException

Get not null constraints on a table.

Parameters:

catName - catalog name.

db_name - database name.

tbl_name - table name.

Returns:

list of not null constraints

Throws:

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

getDefaultConstraints

List<org.apache.hadoop.hive.metastore.api.SQLDefaultConstraint> getDefaultConstraints(String catName,
                                                                                      String db_name,
                                                                                      String tbl_name)
                                                                               throws org.apache.hadoop.hive.metastore.api.MetaException

Get default values for columns in a table.

Parameters:

catName - catalog name

db_name - database name

tbl_name - table name

Returns:

list of default values defined on the table.

Throws:

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

getCheckConstraints

List<org.apache.hadoop.hive.metastore.api.SQLCheckConstraint> getCheckConstraints(String catName,
                                                                                  String db_name,
                                                                                  String tbl_name)
                                                                           throws org.apache.hadoop.hive.metastore.api.MetaException

Get check constraints for columns in a table.

Parameters:

catName - catalog name.

db_name - database name

tbl_name - table name

Returns:

ccheck constraints for this table

Throws:

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

createTableWithConstraints

List<String> createTableWithConstraints(org.apache.hadoop.hive.metastore.api.Table tbl,
                                        List<org.apache.hadoop.hive.metastore.api.SQLPrimaryKey> primaryKeys,
                                        List<org.apache.hadoop.hive.metastore.api.SQLForeignKey> foreignKeys,
                                        List<org.apache.hadoop.hive.metastore.api.SQLUniqueConstraint> uniqueConstraints,
                                        List<org.apache.hadoop.hive.metastore.api.SQLNotNullConstraint> notNullConstraints,
                                        List<org.apache.hadoop.hive.metastore.api.SQLDefaultConstraint> defaultConstraints,
                                        List<org.apache.hadoop.hive.metastore.api.SQLCheckConstraint> checkConstraints)
                                 throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                        org.apache.hadoop.hive.metastore.api.MetaException

Create a table with constraints

Parameters:

tbl - table definition

primaryKeys - primary key definition, or null

foreignKeys - foreign key definition, or null

uniqueConstraints - unique constraints definition, or null

notNullConstraints - not null constraints definition, or null

defaultConstraints - default values definition, or null

Returns:

list of constraint names

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - one of the provided objects is malformed.

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

dropConstraint

default void dropConstraint(String catName,
                            String dbName,
                            String tableName,
                            String constraintName)
                     throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Drop a constraint, any constraint. I have no idea why add and get each have separate methods for each constraint type but drop has only one.

Parameters:

catName - catalog name

dbName - database name

tableName - table name

constraintName - name of the constraint

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no constraint of this name exists

dropConstraint

void dropConstraint(String catName,
                    String dbName,
                    String tableName,
                    String constraintName,
                    boolean missingOk)
             throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Drop a constraint, any constraint. I have no idea why add and get each have separate methods for each constraint type but drop has only one.

Parameters:

catName - catalog name

dbName - database name

tableName - table name

constraintName - name of the constraint

missingOk - if true, it is not an error if there is no constraint of this name. If false and there is no constraint of this name an exception will be thrown.

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no constraint of this name exists and missingOk = false

addPrimaryKeys

List<String> addPrimaryKeys(List<org.apache.hadoop.hive.metastore.api.SQLPrimaryKey> pks)
                     throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                            org.apache.hadoop.hive.metastore.api.MetaException

Add a primary key to a table.

Parameters:

pks - Columns in the primary key.

Returns:

the name of the constraint, as a list of strings.

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - The SQLPrimaryKeys list is malformed

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

addForeignKeys

List<String> addForeignKeys(List<org.apache.hadoop.hive.metastore.api.SQLForeignKey> fks)
                     throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                            org.apache.hadoop.hive.metastore.api.MetaException

Add a foreign key to a table.

Parameters:

fks - foreign key specification

Returns:

foreign key name.

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - the specification is malformed.

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

addUniqueConstraints

List<String> addUniqueConstraints(List<org.apache.hadoop.hive.metastore.api.SQLUniqueConstraint> uks)
                           throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                  org.apache.hadoop.hive.metastore.api.MetaException

Add unique constraints to a table.

Parameters:

uks - unique constraints specification

Returns:

unique constraint names.

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - the specification is malformed.

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

addNotNullConstraints

List<String> addNotNullConstraints(List<org.apache.hadoop.hive.metastore.api.SQLNotNullConstraint> nns)
                            throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                   org.apache.hadoop.hive.metastore.api.MetaException

Add not null constraints to a table.

Parameters:

nns - not null constraint specifications

Returns:

constraint names.

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - the specification is malformed.

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

addDefaultConstraints

List<String> addDefaultConstraints(List<org.apache.hadoop.hive.metastore.api.SQLDefaultConstraint> dv)
                            throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                   org.apache.hadoop.hive.metastore.api.MetaException

Add default values to a table definition

Parameters:

dv - list of default values

Returns:

constraint names

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - the specification is malformed.

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

addCheckConstraints

List<String> addCheckConstraints(List<org.apache.hadoop.hive.metastore.api.SQLCheckConstraint> cc)
                          throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                 org.apache.hadoop.hive.metastore.api.MetaException

Add check constraints to a table

Parameters:

cc - check constraints to add

Returns:

list of constraint names

Throws:

org.apache.hadoop.hive.metastore.api.InvalidObjectException - the specification is malformed

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

getMetastoreDbUuid

String getMetastoreDbUuid()
                   throws org.apache.hadoop.hive.metastore.api.MetaException

Gets the unique id of the backing datastore for the metadata

Returns:

Throws:

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

createResourcePlan

void createResourcePlan(org.apache.hadoop.hive.metastore.api.WMResourcePlan resourcePlan,
                        String copyFrom,
                        int defaultPoolSize)
                 throws org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                        org.apache.hadoop.hive.metastore.api.MetaException,
                        org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                        org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:

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

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

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

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

getResourcePlan

org.apache.hadoop.hive.metastore.api.WMFullResourcePlan getResourcePlan(String name)
                                                                 throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                                        org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

getAllResourcePlans

List<org.apache.hadoop.hive.metastore.api.WMResourcePlan> getAllResourcePlans()
                                                                       throws org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

alterResourcePlan

org.apache.hadoop.hive.metastore.api.WMFullResourcePlan alterResourcePlan(String name,
                                                                          org.apache.hadoop.hive.metastore.api.WMNullableResourcePlan resourcePlan,
                                                                          boolean canActivateDisabled,
                                                                          boolean canDeactivate,
                                                                          boolean isReplace)
                                                                   throws org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                                                                          org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                                          org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                                                                          org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

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

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

getActiveResourcePlan

org.apache.hadoop.hive.metastore.api.WMFullResourcePlan getActiveResourcePlan()
                                                                       throws org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

validateResourcePlan

org.apache.hadoop.hive.metastore.api.WMValidateResourcePlanResponse validateResourcePlan(String name)
                                                                                  throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                                                         org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                                                                         org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

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

dropResourcePlan

void dropResourcePlan(String name)
               throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                      org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

createWMTrigger

void createWMTrigger(org.apache.hadoop.hive.metastore.api.WMTrigger trigger)
              throws org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                     org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                     org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                     org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

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

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

alterWMTrigger

void alterWMTrigger(org.apache.hadoop.hive.metastore.api.WMTrigger trigger)
             throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                    org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                    org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

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

dropWMTrigger

void dropWMTrigger(String resourcePlanName,
                   String triggerName)
            throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                   org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                   org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

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

getTriggersForResourcePlan

List<org.apache.hadoop.hive.metastore.api.WMTrigger> getTriggersForResourcePlan(String resourcePlanName)
                                                                         throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                                                org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

createPool

void createPool(org.apache.hadoop.hive.metastore.api.WMPool pool)
         throws org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

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

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

alterPool

void alterPool(org.apache.hadoop.hive.metastore.api.WMNullablePool pool,
               String poolPath)
        throws org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
               org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
               org.apache.hadoop.hive.metastore.api.InvalidOperationException,
               org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

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

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

dropWMPool

void dropWMPool(String resourcePlanName,
                String poolPath)
         throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

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

createOrUpdateWMMapping

void createOrUpdateWMMapping(org.apache.hadoop.hive.metastore.api.WMMapping mapping,
                             boolean update)
                      throws org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                             org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                             org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                             org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

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

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

dropWMMapping

void dropWMMapping(org.apache.hadoop.hive.metastore.api.WMMapping mapping)
            throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                   org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                   org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

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

createWMTriggerToPoolMapping

void createWMTriggerToPoolMapping(String resourcePlanName,
                                  String triggerName,
                                  String poolPath)
                           throws org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                                  org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                  org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                                  org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

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

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

dropWMTriggerToPoolMapping

void dropWMTriggerToPoolMapping(String resourcePlanName,
                                String triggerName,
                                String poolPath)
                         throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                                org.apache.hadoop.hive.metastore.api.MetaException

Throws:

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

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

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

createISchema

void createISchema(org.apache.hadoop.hive.metastore.api.ISchema schema)
            throws org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                   org.apache.hadoop.hive.metastore.api.MetaException,
                   org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Create a new ISchema.

Parameters:

schema - schema to create

Throws:

org.apache.hadoop.hive.metastore.api.AlreadyExistsException - there's already a schema with this name

org.apache.hadoop.hive.metastore.api.MetaException - general database exception

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

alterISchema

void alterISchema(org.apache.hadoop.hive.metastore.api.ISchemaName schemaName,
                  org.apache.hadoop.hive.metastore.api.ISchema newSchema)
           throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                  org.apache.hadoop.hive.metastore.api.MetaException

Alter an existing ISchema. This assumes the caller has already checked that such a schema exists.

Parameters:

schemaName - name of the schema

newSchema - new schema object

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no function with this name exists

org.apache.hadoop.hive.metastore.api.MetaException - general database exception

getISchema

org.apache.hadoop.hive.metastore.api.ISchema getISchema(org.apache.hadoop.hive.metastore.api.ISchemaName schemaName)
                                                 throws org.apache.hadoop.hive.metastore.api.MetaException

Get an ISchema by name.

Parameters:

schemaName - schema descriptor

Returns:

ISchema

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - general database exception

dropISchema

void dropISchema(org.apache.hadoop.hive.metastore.api.ISchemaName schemaName)
          throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                 org.apache.hadoop.hive.metastore.api.MetaException

Drop an ISchema. This does not check whether there are valid versions of the schema in existence, it assumes the caller has already done that.

Parameters:

schemaName - schema descriptor

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no schema of this name exists

org.apache.hadoop.hive.metastore.api.MetaException - general database exception

addSchemaVersion

void addSchemaVersion(org.apache.hadoop.hive.metastore.api.SchemaVersion schemaVersion)
               throws org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                      org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                      org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                      org.apache.hadoop.hive.metastore.api.MetaException

Create a new version of an existing schema.

Parameters:

schemaVersion - version number

Throws:

org.apache.hadoop.hive.metastore.api.AlreadyExistsException - a version of the schema with the same version number already exists.

org.apache.hadoop.hive.metastore.api.InvalidObjectException - the passed in SchemaVersion object has problems.

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no schema with the passed in name exists.

org.apache.hadoop.hive.metastore.api.MetaException - general database exception

alterSchemaVersion

void alterSchemaVersion(org.apache.hadoop.hive.metastore.api.SchemaVersionDescriptor version,
                        org.apache.hadoop.hive.metastore.api.SchemaVersion newVersion)
                 throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                        org.apache.hadoop.hive.metastore.api.MetaException

Alter a schema version. Note that the Thrift interface only supports changing the serde mapping and states. This method does not guarantee it will check anymore than that. This method does not understand the state transitions and just assumes that the new state it is passed is reasonable.

Parameters:

version - version descriptor for the schema

newVersion - altered SchemaVersion

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no such version of the named schema exists

org.apache.hadoop.hive.metastore.api.MetaException - general database exception

getSchemaVersion

org.apache.hadoop.hive.metastore.api.SchemaVersion getSchemaVersion(org.apache.hadoop.hive.metastore.api.SchemaVersionDescriptor version)
                                                             throws org.apache.hadoop.hive.metastore.api.MetaException

Get a specific schema version.

Parameters:

version - version descriptor for the schema

Returns:

the SchemaVersion

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - general database exception

getLatestSchemaVersion

org.apache.hadoop.hive.metastore.api.SchemaVersion getLatestSchemaVersion(org.apache.hadoop.hive.metastore.api.ISchemaName schemaName)
                                                                   throws org.apache.hadoop.hive.metastore.api.MetaException

Get the latest version of a schema.

Parameters:

schemaName - name of the schema

Returns:

latest version of the schema

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - general database exception

getAllSchemaVersion

List<org.apache.hadoop.hive.metastore.api.SchemaVersion> getAllSchemaVersion(org.apache.hadoop.hive.metastore.api.ISchemaName schemaName)
                                                                      throws org.apache.hadoop.hive.metastore.api.MetaException

Get all of the versions of a schema

Parameters:

schemaName - name of the schema

Returns:

all versions of the schema

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - general database exception

getSchemaVersionsByColumns

List<org.apache.hadoop.hive.metastore.api.SchemaVersion> getSchemaVersionsByColumns(String colName,
                                                                                    String colNamespace,
                                                                                    String type)
                                                                             throws org.apache.hadoop.hive.metastore.api.MetaException

Find all SchemaVersion objects that match a query. The query will select all SchemaVersions that are equal to all of the non-null passed in arguments. That is, if arguments colName='name', colNamespace=null, type='string' are passed in, then all schemas that have a column with colName 'name' and type 'string' will be returned.

Parameters:

colName - column name. Null is ok, which will cause this field to not be used in the query.

colNamespace - column namespace. Null is ok, which will cause this field to not be used in the query.

type - column type. Null is ok, which will cause this field to not be used in the query.

Returns:

List of all SchemaVersions that match. Note that there is no expectation that these SchemaVersions derive from the same ISchema. The list will be empty if there are no matching SchemaVersions.

Throws:

org.apache.hadoop.hive.metastore.api.MetaException - general database exception

dropSchemaVersion

void dropSchemaVersion(org.apache.hadoop.hive.metastore.api.SchemaVersionDescriptor version)
                throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                       org.apache.hadoop.hive.metastore.api.MetaException

Drop a version of the schema.

Parameters:

version - version descriptor for the schema

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no such version of the named schema exists

org.apache.hadoop.hive.metastore.api.MetaException - general database exception

getSerDeInfo

org.apache.hadoop.hive.metastore.api.SerDeInfo getSerDeInfo(String serDeName)
                                                     throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                            org.apache.hadoop.hive.metastore.api.MetaException

Get serde information

Parameters:

serDeName - name of the SerDe

Returns:

the SerDe, or null if there is no such serde

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException - no serde with this name exists

org.apache.hadoop.hive.metastore.api.MetaException - general database exception

addSerde

void addSerde(org.apache.hadoop.hive.metastore.api.SerDeInfo serde)
       throws org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
              org.apache.hadoop.hive.metastore.api.MetaException

Add a serde

Parameters:

serde - serde to add

Throws:

org.apache.hadoop.hive.metastore.api.AlreadyExistsException - a serde of this name already exists

org.apache.hadoop.hive.metastore.api.MetaException - general database exception

addRuntimeStat

void addRuntimeStat(org.apache.hadoop.hive.metastore.api.RuntimeStat stat)
             throws org.apache.hadoop.hive.metastore.api.MetaException

Adds a RuntimeStat for persistence.

Throws:

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

getRuntimeStats

List<org.apache.hadoop.hive.metastore.api.RuntimeStat> getRuntimeStats(int maxEntries,
                                                                       int maxCreateTime)
                                                                throws org.apache.hadoop.hive.metastore.api.MetaException

Reads runtime statistic entries.

Throws:

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

deleteRuntimeStats

int deleteRuntimeStats(int maxRetainSecs)
                throws org.apache.hadoop.hive.metastore.api.MetaException

Removes outdated statistics.

Throws:

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

getTableNamesWithStats

List<MetaStoreUtils.FullTableName> getTableNamesWithStats()
                                                   throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                          org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:

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

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

getAllTableNamesForStats

List<MetaStoreUtils.FullTableName> getAllTableNamesForStats()
                                                     throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                            org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:

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

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

getPartitionColsWithStats

Map<String,List<String>> getPartitionColsWithStats(String catName,
                                                   String dbName,
                                                   String tableName)
                                            throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                   org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:

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

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