public class ObjectStore extends Object implements RawStore, org.apache.hadoop.conf.Configurable
Modifier and Type | Class and Description |
---|---|
class |
ObjectStore.GetDbHelper |
class |
ObjectStore.GetHelper<T>
Helper class for getting stuff w/transaction, direct SQL, perf logging, etc.
|
static class |
ObjectStore.QueryWrapper
A Autocloseable wrapper around Query class to pass the Query object to the caller and let the caller release
the resources when the QueryWrapper goes out of scope
|
class |
ObjectStore.UpdateMDatabaseURIRetVal |
class |
ObjectStore.UpdateMStorageDescriptorTblURIRetVal |
class |
ObjectStore.UpdatePropURIRetVal |
class |
ObjectStore.UpdateSerdeURIRetVal |
RawStore.CanNotRetry
Constructor and Description |
---|
ObjectStore() |
Modifier and Type | Method and Description |
---|---|
List<String> |
addCheckConstraints(List<SQLCheckConstraint> nns)
Add check constraints to a table
|
List<String> |
addDefaultConstraints(List<SQLDefaultConstraint> nns)
Add default values to a table definition
|
List<String> |
addForeignKeys(List<SQLForeignKey> fks)
Add a foreign key to a table.
|
int |
addMasterKey(String key) |
void |
addNotificationEvent(NotificationEvent entry)
Add a notification entry.
|
List<String> |
addNotNullConstraints(List<SQLNotNullConstraint> nns)
Add not null constraints to a table.
|
boolean |
addPartition(Partition part)
Add a partition.
|
boolean |
addPartitions(String catName,
String dbName,
String tblName,
List<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<SQLPrimaryKey> pks)
Add a primary key to a table.
|
boolean |
addRole(String roleName,
String ownerName) |
void |
addRuntimeStat(RuntimeStat stat)
Adds a RuntimeStat for persistence.
|
void |
addSchemaVersion(SchemaVersion schemaVersion)
Create a new version of an existing schema.
|
void |
addSerde(SerDeInfo serde)
Add a serde
|
boolean |
addToken(String tokenId,
String delegationToken) |
List<String> |
addUniqueConstraints(List<SQLUniqueConstraint> uks)
Add unique constraints to a table.
|
void |
alterCatalog(String catName,
Catalog cat)
Alter an existing catalog.
|
boolean |
alterDatabase(String catName,
String dbName,
Database db)
Alter the database object in metastore.
|
void |
alterFunction(String catName,
String dbName,
String funcName,
Function newFunction)
Alter function based on new function specs.
|
void |
alterISchema(ISchemaName schemaName,
ISchema newSchema)
Alter an existing ISchema.
|
void |
alterPartition(String catName,
String dbname,
String name,
List<String> part_vals,
Partition newPart)
Alter a partition.
|
void |
alterPartitions(String catName,
String dbname,
String name,
List<List<String>> part_vals,
List<Partition> newParts)
Alter a set of partitions.
|
void |
alterPool(WMNullablePool pool,
String poolPath) |
WMFullResourcePlan |
alterResourcePlan(String name,
WMNullableResourcePlan changes,
boolean canActivateDisabled,
boolean canDeactivate,
boolean isReplace) |
void |
alterSchemaVersion(SchemaVersionDescriptor version,
SchemaVersion newVersion)
Alter a schema version.
|
void |
alterTable(String catName,
String dbname,
String name,
Table newTable)
Alter a table.
|
void |
alterWMTrigger(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(Catalog cat)
Create a new catalog.
|
void |
createDatabase(Database db)
Create a database.
|
void |
createFunction(Function func)
Register a user-defined function based on the function specification passed in.
|
void |
createISchema(ISchema schema)
Create a new ISchema.
|
void |
createOrUpdateWMMapping(WMMapping mapping,
boolean update) |
void |
createPool(WMPool pool) |
void |
createResourcePlan(WMResourcePlan resourcePlan,
String copyFromName,
int defaultPoolSize) |
void |
createTable(Table tbl) |
List<String> |
createTableWithConstraints(Table tbl,
List<SQLPrimaryKey> primaryKeys,
List<SQLForeignKey> foreignKeys,
List<SQLUniqueConstraint> uniqueConstraints,
List<SQLNotNullConstraint> notNullConstraints,
List<SQLDefaultConstraint> defaultConstraints,
List<SQLCheckConstraint> checkConstraints)
Create a table with constraints
|
boolean |
createType(Type type) |
void |
createWMTrigger(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> partVals)
Check whether a partition exists.
|
void |
dropCatalog(String catalogName)
Drop a catalog.
|
void |
dropConstraint(String catName,
String dbName,
String tableName,
String constraintName,
boolean missingOk)
Drop a constraint, any constraint.
|
boolean |
dropDatabase(String catName,
String dbname)
Drop a database.
|
void |
dropFunction(String catName,
String dbName,
String funcName)
Drop a function definition.
|
void |
dropISchema(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(SchemaVersionDescriptor version)
Drop a version of the schema.
|
boolean |
dropTable(String catName,
String dbName,
String tableName)
Drop a table.
|
boolean |
dropType(String typeName) |
void |
dropWMMapping(WMMapping mapping) |
void |
dropWMPool(String resourcePlanName,
String poolPath) |
void |
dropWMTrigger(String resourcePlanName,
String triggerName) |
void |
dropWMTriggerToPoolMapping(String resourcePlanName,
String triggerName,
String poolPath) |
Collection<?> |
executeJDOQLSelect(String queryStr,
ObjectStore.QueryWrapper queryWrapper)
The following API
- executeJDOQLSelect
is used by HiveMetaTool.
|
long |
executeJDOQLUpdate(String queryStr)
The following API
- executeJDOQLUpdate
is used by HiveMetaTool.
|
void |
flushCache() |
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).
|
WMFullResourcePlan |
getActiveResourcePlan() |
List<String> |
getAllDatabases(String catName)
Get names of all the databases in a catalog.
|
List<Function> |
getAllFunctions(String catName)
Retrieve all functions.
|
List<WMResourcePlan> |
getAllResourcePlans() |
List<SchemaVersion> |
getAllSchemaVersion(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() |
Catalog |
getCatalog(String catalogName)
Get a catalog.
|
List<String> |
getCatalogs()
Get all the catalogs.
|
List<SQLCheckConstraint> |
getCheckConstraints(String catName,
String db_name,
String tbl_name)
Get check constraints for columns in a table.
|
protected List<SQLCheckConstraint> |
getCheckConstraintsInternal(String catName,
String db_name_input,
String tbl_name_input,
boolean allowSql,
boolean allowJdo) |
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.conf.Configuration |
getConf() |
CurrentNotificationEventId |
getCurrentNotificationEventId()
Get the last issued notification event id.
|
Database |
getDatabase(String catalogName,
String name)
Get a database.
|
int |
getDatabaseCount()
Gets total number of databases.
|
Database |
getDatabaseInternal(String catalogName,
String name) |
List<String> |
getDatabases(String catName,
String pattern)
Get all database in a catalog having names that match a pattern.
|
PrincipalPrivilegeSet |
getDBPrivilegeSet(String catName,
String dbName,
String userName,
List<String> groupNames)
Get privileges for a database for a user.
|
List<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,
FileMetadataExprType type,
byte[] expr,
ByteBuffer[] metadatas,
ByteBuffer[] stripeBitsets,
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(FileMetadataExprType type)
Gets file metadata handler for the corresponding type.
|
List<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.
|
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.
|
ISchema |
getISchema(ISchemaName schemaName)
Get an ISchema by name.
|
Database |
getJDODatabase(String catName,
String name) |
SchemaVersion |
getLatestSchemaVersion(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() |
NotificationEventResponse |
getNextNotification(NotificationEventRequest rqst)
Get the next notification event.
|
NotificationEventsCountResponse |
getNotificationEventsCount(NotificationEventsCountRequest rqst)
Get the number of events corresponding to given database with fromEventId.
|
List<SQLNotNullConstraint> |
getNotNullConstraints(String catName,
String db_name,
String tbl_name)
Get not null constraints on a table.
|
protected List<SQLNotNullConstraint> |
getNotNullConstraintsInternal(String catName,
String db_name_input,
String tbl_name_input,
boolean allowSql,
boolean allowJdo) |
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.
|
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<ColumnStatistics> |
getPartitionColumnStatistics(String catName,
String dbName,
String tableName,
List<String> partNames,
List<String> colNames)
Get statistics for a partition for a set of columns.
|
protected List<ColumnStatistics> |
getPartitionColumnStatisticsInternal(String catName,
String dbName,
String tableName,
List<String> partNames,
List<String> colNames,
boolean allowSql,
boolean allowJdo) |
int |
getPartitionCount()
Gets total number of partitions.
|
PrincipalPrivilegeSet |
getPartitionPrivilegeSet(String catName,
String dbName,
String tableName,
String partition,
String userName,
List<String> groupNames)
Get privileges for a partition for a user.
|
List<Partition> |
getPartitions(String catName,
String dbName,
String tableName,
int maxParts)
Get some or all partitions for a table.
|
boolean |
getPartitionsByExpr(String catName,
String dbName,
String tblName,
byte[] expr,
String defaultPartitionName,
short maxParts,
List<Partition> result)
Get partitions using an already parsed expression.
|
protected boolean |
getPartitionsByExprInternal(String catName,
String dbName,
String tblName,
byte[] expr,
String defaultPartitionName,
short maxParts,
List<Partition> result,
boolean allowSql,
boolean allowJdo) |
List<Partition> |
getPartitionsByFilter(String catName,
String dbName,
String tblName,
String filter,
short maxParts)
Get partitions with a filter.
|
protected List<Partition> |
getPartitionsByFilterInternal(String catName,
String dbName,
String tblName,
String filter,
short maxParts,
boolean allowSql,
boolean allowJdo) |
List<Partition> |
getPartitionsByNames(String catName,
String dbName,
String tblName,
List<String> partNames)
Get partitions by name.
|
protected List<Partition> |
getPartitionsByNamesInternal(String catName,
String dbName,
String tblName,
List<String> partNames,
boolean allowSql,
boolean allowJdo) |
protected List<Partition> |
getPartitionsInternal(String catName,
String dbName,
String tblName,
int maxParts,
boolean allowSql,
boolean allowJdo) |
List<Partition> |
getPartitionsWithAuth(String catName,
String dbName,
String tblName,
short max,
String userName,
List<String> groupNames)
Fetch some or all partitions for a table, along with privilege information for a particular
user.
|
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.
|
javax.jdo.PersistenceManager |
getPersistenceManager() |
List<SQLPrimaryKey> |
getPrimaryKeys(String catName,
String db_name,
String tbl_name)
Get the primary associated with a table.
|
WMFullResourcePlan |
getResourcePlan(String name) |
Role |
getRole(String roleName) |
List<RuntimeStat> |
getRuntimeStats(int maxEntries,
int maxCreateTime)
Reads runtime statistic entries.
|
SchemaVersion |
getSchemaVersion(SchemaVersionDescriptor version)
Get a specific schema version.
|
List<SchemaVersion> |
getSchemaVersionsByColumns(String colName,
String colNamespace,
String type)
Find all SchemaVersion objects that match a query.
|
SerDeInfo |
getSerDeInfo(String serDeName)
Get serde information
|
Table |
getTable(String catName,
String dbName,
String tableName)
Get a table object.
|
ColumnStatistics |
getTableColumnStatistics(String catName,
String dbName,
String tableName,
List<String> colNames)
Returns the relevant column statistics for a given column in a given table in a given database
if such statistics exist.
|
protected ColumnStatistics |
getTableColumnStatisticsInternal(String catName,
String dbName,
String tableName,
List<String> colNames,
boolean allowSql,
boolean allowJdo) |
int |
getTableCount()
Gets total number of tables.
|
List<TableMeta> |
getTableMeta(String catName,
String dbNames,
String tableNames,
List<String> tableTypes) |
List<MetaStoreUtils.FullTableName> |
getTableNamesWithStats() |
List<Table> |
getTableObjectsByName(String catName,
String db,
List<String> tbl_names) |
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.
|
protected List<String> |
getTablesInternal(String catName,
String dbName,
String pattern,
TableType tableType,
boolean allowSql,
boolean allowJdo) |
String |
getToken(String tokenId) |
List<WMTrigger> |
getTriggersForResourcePlan(String resourcePlanName) |
Type |
getType(String typeName) |
List<SQLUniqueConstraint> |
getUniqueConstraints(String catName,
String db_name,
String tbl_name)
Get unique constraints associated with a table.
|
PrincipalPrivilegeSet |
getUserPrivilegeSet(String userName,
List<String> groupNames) |
boolean |
grantPrivileges(PrivilegeBag privileges) |
boolean |
grantRole(Role role,
String userName,
PrincipalType principalType,
String grantor,
PrincipalType grantorType,
boolean grantOption) |
boolean |
isActiveTransaction() |
boolean |
isFileMetadataSupported() |
boolean |
isPartitionMarkedForEvent(String catName,
String dbName,
String tblName,
Map<String,String> partName,
PartitionEventType evtType) |
List<HiveObjectPrivilege> |
listAllTableGrants(String principalName,
PrincipalType principalType,
String catName,
String dbName,
String tableName)
For a given principal name and type, list the Table Grants
|
List<HiveObjectPrivilege> |
listDBGrantsAll(String catName,
String dbName)
Find all the privileges for a given database.
|
Set<String> |
listFSRoots()
The following API
- listFSRoots
is used by HiveMetaTool.
|
List<HiveObjectPrivilege> |
listGlobalGrantsAll() |
List<MRoleMap> |
listMRoleMembers(String roleName) |
List<MRoleMap> |
listMRoles(String principalName,
PrincipalType principalType) |
List<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<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 dbName,
String tableName,
short max)
Get a partial or complete list of names for partitions of a table.
|
List<String> |
listPartitionNamesPs(String catName,
String dbName,
String tableName,
List<String> part_vals,
short max_parts)
Lists partition names that match a given partial specification
|
List<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.
|
PartitionValuesResponse |
listPartitionValues(String catName,
String dbName,
String tableName,
List<FieldSchema> cols,
boolean applyDistinct,
String filter,
boolean ascending,
List<FieldSchema> order,
long maxParts)
Get a list of partition values as one big struct.
|
List<HiveObjectPrivilege> |
listPrincipalDBGrants(String principalName,
PrincipalType principalType,
String catName,
String dbName)
For a given principal name and type, list the DB Grants
|
List<HiveObjectPrivilege> |
listPrincipalDBGrantsAll(String principalName,
PrincipalType principalType)
List all DB grants for a given principal.
|
List<HiveObjectPrivilege> |
listPrincipalGlobalGrants(String principalName,
PrincipalType principalType) |
List<HiveObjectPrivilege> |
listPrincipalPartitionColumnGrants(String principalName,
PrincipalType principalType,
String catName,
String dbName,
String tableName,
List<String> partValues,
String partitionName,
String columnName)
For a given principal name and type, list the Table Grants
|
List<HiveObjectPrivilege> |
listPrincipalPartitionColumnGrantsAll(String principalName,
PrincipalType principalType)
List all Partition column grants for a given principal
|
List<HiveObjectPrivilege> |
listPrincipalPartitionGrants(String principalName,
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<HiveObjectPrivilege> |
listPrincipalPartitionGrantsAll(String principalName,
PrincipalType principalType)
List all Partition grants for a given principal
|
List<HiveObjectPrivilege> |
listPrincipalTableColumnGrants(String principalName,
PrincipalType principalType,
String catName,
String dbName,
String tableName,
String columnName)
For a given principal name and type, list the Table Grants
|
List<HiveObjectPrivilege> |
listPrincipalTableColumnGrantsAll(String principalName,
PrincipalType principalType)
List all Table column grants for a given principal
|
List<HiveObjectPrivilege> |
listPrincipalTableGrantsAll(String principalName,
PrincipalType principalType)
List all Table grants for a given principal
|
List<RolePrincipalGrant> |
listRoleMembers(String roleName)
Get the role to principal grant mapping for given role
|
List<String> |
listRoleNames() |
List<Role> |
listRoles(String principalName,
PrincipalType principalType) |
List<RolePrincipalGrant> |
listRolesWithGrants(String principalName,
PrincipalType principalType) |
List<HiveObjectPrivilege> |
listTableColumnGrantsAll(String catName,
String dbName,
String tableName,
String columnName)
Find all of the privileges for a given column in a given table.
|
List<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 maxTables)
Gets a list of tables based on a filter string and filter type.
|
Table |
markPartitionForEvent(String catName,
String dbName,
String tblName,
Map<String,String> partName,
PartitionEventType evtType) |
boolean |
openTransaction()
Opens a new one or the one already created Every call of this function must
have corresponding commit or rollback function call
|
void |
putFileMetadata(List<Long> fileIds,
List<ByteBuffer> metadata,
FileMetadataExprType type) |
boolean |
refreshPrivileges(HiveObjectRef objToRefresh,
String authorizer,
PrivilegeBag grantPrivileges) |
boolean |
removeMasterKey(Integer id) |
boolean |
removeRole(String roleName) |
boolean |
removeToken(String tokenId) |
boolean |
revokePrivileges(PrivilegeBag privileges,
boolean grantOption) |
boolean |
revokeRole(Role role,
String userName,
PrincipalType principalType,
boolean grantOption) |
void |
rollbackTransaction()
Rolls back the current transaction if it is active
|
void |
setConf(org.apache.hadoop.conf.Configuration conf)
Called whenever this object is instantiated using ReflectionUtils, and also
on connection retries.
|
void |
setMetaStoreSchemaVersion(String schemaVersion,
String comment) |
static void |
setSchemaVerified(boolean val) |
static void |
setTwoMetastoreTesting(boolean twoMetastoreTesting)
To make possible to run multiple metastore in unit test
|
void |
shutdown() |
static void |
unCacheDataNucleusClassLoaders()
Removed cached classloaders from DataNucleus
DataNucleus caches classloaders in NucleusContext.
|
void |
updateCreationMetadata(String catName,
String dbname,
String tablename,
CreationMetadata cm)
Update creation metadata for a materialized view.
|
void |
updateMasterKey(Integer id,
String key) |
ObjectStore.UpdateMDatabaseURIRetVal |
updateMDatabaseURI(URI oldLoc,
URI newLoc,
boolean dryRun)
The following APIs
- updateMDatabaseURI
is used by HiveMetaTool.
|
ObjectStore.UpdatePropURIRetVal |
updateMStorageDescriptorTblPropURI(URI oldLoc,
URI newLoc,
String tblPropKey,
boolean isDryRun)
Deprecated.
|
ObjectStore.UpdateMStorageDescriptorTblURIRetVal |
updateMStorageDescriptorTblURI(URI oldLoc,
URI newLoc,
boolean isDryRun)
The following APIs
- updateMStorageDescriptorTblURI
is used by HiveMetaTool.
|
boolean |
updatePartitionColumnStatistics(ColumnStatistics colStats,
List<String> partVals)
Persists the given column statistics object to the metastore
|
ObjectStore.UpdateSerdeURIRetVal |
updateSerdeURI(URI oldLoc,
URI newLoc,
String serdeProp,
boolean isDryRun)
The following APIs
- updateSerdeURI
is used by HiveMetaTool.
|
boolean |
updateTableColumnStatistics(ColumnStatistics colStats)
Persists the given column statistics object to the metastore
|
ObjectStore.UpdatePropURIRetVal |
updateTblPropURI(URI oldLoc,
URI newLoc,
String tblPropKey,
boolean isDryRun)
The following APIs
- updateMStorageDescriptorTblPropURI
is used by HiveMetaTool.
|
WMValidateResourcePlanResponse |
validateResourcePlan(String name) |
void |
validateTableCols(Table table,
List<String> colNames) |
void |
verifySchema() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
dropConstraint
public org.apache.hadoop.conf.Configuration getConf()
getConf
in interface org.apache.hadoop.conf.Configurable
public void setConf(org.apache.hadoop.conf.Configuration conf)
setConf
in interface org.apache.hadoop.conf.Configurable
@InterfaceAudience.LimitedPrivate(value="HCATALOG") @InterfaceStability.Evolving public javax.jdo.PersistenceManager getPersistenceManager()
public boolean openTransaction()
openTransaction
in interface RawStore
public boolean commitTransaction()
commitTransaction
in interface RawStore
public boolean isActiveTransaction()
isActiveTransaction
in interface RawStore
public void rollbackTransaction()
rollbackTransaction
in interface RawStore
public void createCatalog(Catalog cat) throws MetaException
RawStore
createCatalog
in interface RawStore
cat
- Catalog to create.MetaException
- if something goes wrong, usually in storing it to the database.public void alterCatalog(String catName, Catalog cat) throws MetaException, InvalidOperationException
RawStore
alterCatalog
in interface RawStore
catName
- name of the catalog to alter.cat
- new version of the catalog.MetaException
- something went wrong, usually in the database.InvalidOperationException
- attempt to change something about the catalog that is not
changeable, like the name.public Catalog getCatalog(String catalogName) throws NoSuchObjectException, MetaException
RawStore
getCatalog
in interface RawStore
catalogName
- name of the catalog.NoSuchObjectException
- no catalog of this name exists.MetaException
- if something goes wrong, usually in reading it from the database.public List<String> getCatalogs() throws MetaException
RawStore
getCatalogs
in interface RawStore
MetaException
- if something goes wrong, usually in reading from the database.public void dropCatalog(String catalogName) throws NoSuchObjectException, MetaException
RawStore
dropCatalog
in interface RawStore
catalogName
- name of the catalog to drop.NoSuchObjectException
- no catalog of this name exists.MetaException
- could mean the catalog isn't empty, could mean general database error.public void createDatabase(Database db) throws InvalidObjectException, MetaException
RawStore
createDatabase
in interface RawStore
db
- database to create.InvalidObjectException
- not sure it actually ever throws this.MetaException
- if something goes wrong, usually in writing it to the database.public Database getDatabase(String catalogName, String name) throws NoSuchObjectException
RawStore
getDatabase
in interface RawStore
catalogName
- catalog the database is in.name
- name of the database.NoSuchObjectException
- if no such database exists.public Database getDatabaseInternal(String catalogName, String name) throws MetaException, NoSuchObjectException
MetaException
NoSuchObjectException
public Database getJDODatabase(String catName, String name) throws NoSuchObjectException
NoSuchObjectException
public boolean alterDatabase(String catName, String dbName, Database db) throws MetaException, NoSuchObjectException
alterDatabase
in interface RawStore
dbName
- the database namedb
- the Hive Database objectcatName
- name of the catalog the database is in.MetaException
NoSuchObjectException
public boolean dropDatabase(String catName, String dbname) throws NoSuchObjectException, MetaException
RawStore
dropDatabase
in interface RawStore
catName
- catalog the database is in.dbname
- name of the database.NoSuchObjectException
- no database in this catalog of this name to dropMetaException
- something went wrong, usually with the database.public List<String> getDatabases(String catName, String pattern) throws MetaException
RawStore
getDatabases
in interface RawStore
catName
- name of the catalog to search for databases inpattern
- pattern names should matchMetaException
- something went wrong, usually with the database.public List<String> getAllDatabases(String catName) throws MetaException
RawStore
getAllDatabases
in interface RawStore
catName
- name of the catalog to search for databases inMetaException
- something went wrong, usually with the database.public boolean createType(Type type)
createType
in interface RawStore
public List<String> createTableWithConstraints(Table tbl, List<SQLPrimaryKey> primaryKeys, List<SQLForeignKey> foreignKeys, List<SQLUniqueConstraint> uniqueConstraints, List<SQLNotNullConstraint> notNullConstraints, List<SQLDefaultConstraint> defaultConstraints, List<SQLCheckConstraint> checkConstraints) throws InvalidObjectException, MetaException
RawStore
createTableWithConstraints
in interface RawStore
tbl
- table definitionprimaryKeys
- primary key definition, or nullforeignKeys
- foreign key definition, or nulluniqueConstraints
- unique constraints definition, or nullnotNullConstraints
- not null constraints definition, or nulldefaultConstraints
- default values definition, or nullInvalidObjectException
- one of the provided objects is malformed.MetaException
- error accessing the RDBMSpublic void createTable(Table tbl) throws InvalidObjectException, MetaException
createTable
in interface RawStore
InvalidObjectException
MetaException
public boolean dropTable(String catName, String dbName, String tableName) throws MetaException, NoSuchObjectException, InvalidObjectException, InvalidInputException
RawStore
dropTable
in interface RawStore
catName
- catalog the table is indbName
- database the table is intableName
- table nameMetaException
- something went wrong, usually in the RDBMS or storageNoSuchObjectException
- No table of this nameInvalidObjectException
- Don't think this is ever actually thrownInvalidInputException
- Don't think this is ever actually thrownpublic Table getTable(String catName, String dbName, String tableName) throws MetaException
RawStore
getTable
in interface RawStore
catName
- catalog the table is in.dbName
- database the table is in.tableName
- table name.MetaException
- something went wrong in the RDBMSpublic List<String> getTables(String catName, String dbName, String pattern) throws MetaException
RawStore
getTables
in interface RawStore
catName
- catalog to search indbName
- database to search inpattern
- pattern to matchMetaException
- failure in querying the RDBMSpublic List<String> getTables(String catName, String dbName, String pattern, TableType tableType) throws MetaException
RawStore
getTables
in interface RawStore
catName
- catalog to search indbName
- database to search inpattern
- pattern to matchtableType
- type of table to look forMetaException
- failure in querying the RDBMSpublic List<MetaStoreUtils.FullTableName> getTableNamesWithStats() throws MetaException, NoSuchObjectException
getTableNamesWithStats
in interface RawStore
MetaException
NoSuchObjectException
public Map<String,List<String>> getPartitionColsWithStats(String catName, String dbName, String tableName) throws MetaException, NoSuchObjectException
getPartitionColsWithStats
in interface RawStore
MetaException
NoSuchObjectException
public List<MetaStoreUtils.FullTableName> getAllTableNamesForStats() throws MetaException, NoSuchObjectException
getAllTableNamesForStats
in interface RawStore
MetaException
NoSuchObjectException
protected List<String> getTablesInternal(String catName, String dbName, String pattern, TableType tableType, boolean allowSql, boolean allowJdo) throws MetaException, NoSuchObjectException
MetaException
NoSuchObjectException
public List<String> getMaterializedViewsForRewriting(String catName, String dbName) throws MetaException, NoSuchObjectException
RawStore
getMaterializedViewsForRewriting
in interface RawStore
catName
- catalog namedbName
- database nameMetaException
- error querying the RDBMSNoSuchObjectException
- no such databasepublic int getDatabaseCount() throws MetaException
RawStore
getDatabaseCount
in interface RawStore
MetaException
public int getPartitionCount() throws MetaException
RawStore
getPartitionCount
in interface RawStore
MetaException
public int getTableCount() throws MetaException
RawStore
getTableCount
in interface RawStore
MetaException
public List<TableMeta> getTableMeta(String catName, String dbNames, String tableNames, List<String> tableTypes) throws MetaException
getTableMeta
in interface RawStore
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.MetaException
- failure in querying the RDBMS.public List<String> getAllTables(String catName, String dbName) throws MetaException
RawStore
getAllTables
in interface RawStore
catName
- catalog name.dbName
- database name.MetaException
- failure in querying the RDBMS.public List<Table> getTableObjectsByName(String catName, String db, List<String> tbl_names) throws MetaException, UnknownDBException
getTableObjectsByName
in interface RawStore
catName
- catalog namedb
- The name of the database from which to retrieve the tablestbl_names
- The names of the tables to retrieve.MetaException
- failure in querying the RDBMS.UnknownDBException
public boolean addPartitions(String catName, String dbName, String tblName, List<Partition> parts) throws InvalidObjectException, MetaException
RawStore
addPartitions
in interface RawStore
catName
- catalog name.dbName
- database name.tblName
- table name.parts
- list of partitions to be added.InvalidObjectException
- never throws this AFAICTMetaException
- the partitions don't belong to the indicated table or error writing to
the RDBMS.public boolean addPartitions(String catName, String dbName, String tblName, PartitionSpecProxy partitionSpec, boolean ifNotExists) throws InvalidObjectException, MetaException
RawStore
addPartitions
in interface RawStore
catName
- catalog name.dbName
- database name.tblName
- table name.partitionSpec
- specification for the partitionifNotExists
- 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.InvalidObjectException
- The passed in partition spec or table specification is invalid.MetaException
- error writing to RDBMS.public boolean addPartition(Partition part) throws InvalidObjectException, MetaException
RawStore
addPartition
in interface RawStore
part
- partition to addInvalidObjectException
- the provided partition object is not valid.MetaException
- error writing to the RDBMS.public Partition getPartition(String catName, String dbName, String tableName, List<String> part_vals) throws NoSuchObjectException, MetaException
RawStore
getPartition
in interface RawStore
catName
- catalog name.dbName
- database name.tableName
- table name.part_vals
- partition values for this table.NoSuchObjectException
- no partition matching this specification exists.MetaException
- error reading from RDBMS.public boolean dropPartition(String catName, String dbName, String tableName, List<String> part_vals) throws MetaException, NoSuchObjectException, InvalidObjectException, InvalidInputException
RawStore
dropPartition
in interface RawStore
catName
- catalog name.dbName
- database name.tableName
- table name.part_vals
- list of partition values.MetaException
- Error accessing the RDBMS.NoSuchObjectException
- no partition matching this description existsInvalidObjectException
- error dropping the statistics for the partitionInvalidInputException
- error dropping the statistics for the partitionpublic void dropPartitions(String catName, String dbName, String tblName, List<String> partNames) throws MetaException, NoSuchObjectException
RawStore
dropPartitions
in interface RawStore
catName
- catalog name.dbName
- database name.tblName
- table namepartNames
- list of partition names.MetaException
- error access RDBMS or storage.NoSuchObjectException
- One or more of the partitions does not exist.public List<Partition> getPartitions(String catName, String dbName, String tableName, int maxParts) throws MetaException, NoSuchObjectException
RawStore
getPartitions
in interface RawStore
catName
- catalog name.dbName
- database name.tableName
- table namemaxParts
- maximum number of partitions, or -1 to get all partitions.MetaException
- error access the RDBMS.NoSuchObjectException
- no such table existsprotected List<Partition> getPartitionsInternal(String catName, String dbName, String tblName, int maxParts, boolean allowSql, boolean allowJdo) throws MetaException, NoSuchObjectException
MetaException
NoSuchObjectException
public List<Partition> getPartitionsWithAuth(String catName, String dbName, String tblName, short max, String userName, List<String> groupNames) throws MetaException, InvalidObjectException
RawStore
getPartitionsWithAuth
in interface RawStore
catName
- catalog name.dbName
- database name.tblName
- table name.max
- maximum number of partitions to fetch, -1 for all partitions.userName
- user to get privilege information for.groupNames
- groups to get privilege information for.MetaException
- error access the RDBMS.InvalidObjectException
- error fetching privilege information.public Partition getPartitionWithAuth(String catName, String dbName, String tblName, List<String> partVals, String user_name, List<String> group_names) throws NoSuchObjectException, MetaException, InvalidObjectException
RawStore
getPartitionWithAuth
in interface RawStore
catName
- catalog name.dbName
- database name.tblName
- table name.partVals
- partition valuesuser_name
- user to get privilege information for.group_names
- groups to get privilege information for.NoSuchObjectException
- no such partition existsMetaException
- error accessing the RDBMS.InvalidObjectException
- error fetching privilege informationpublic List<String> listPartitionNames(String catName, String dbName, String tableName, short max) throws MetaException
RawStore
listPartitionNames
in interface RawStore
catName
- catalog name.dbName
- database name.tableName
- table name.max
- maximum number of partitions to retrieve, -1 for all.MetaException
- there was an error accessing the RDBMSpublic PartitionValuesResponse listPartitionValues(String catName, String dbName, String tableName, List<FieldSchema> cols, boolean applyDistinct, String filter, boolean ascending, List<FieldSchema> order, long maxParts) throws MetaException
RawStore
listPartitionValues
in interface RawStore
catName
- catalog name.dbName
- database name.tableName
- table name.cols
- partition key columnsapplyDistinct
- whether to apply distinct to the listfilter
- filter to apply to the partition namesascending
- whether to put in ascending orderorder
- whether to ordermaxParts
- maximum number of parts to return, or -1 for allMetaException
- error access the RDBMSpublic List<Partition> listPartitionsPsWithAuth(String catName, String db_name, String tbl_name, List<String> part_vals, short max_parts, String userName, List<String> groupNames) throws MetaException, InvalidObjectException, NoSuchObjectException
RawStore
listPartitionsPsWithAuth
in interface RawStore
catName
- catalog name.db_name
- The name of the database which has the partitionstbl_name
- The name of the table which has the partitionspart_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 returnuserName
- The user name for the partition for authentication privilegesgroupNames
- The groupNames for the partition for authentication privilegesMetaException
- error access RDBMSInvalidObjectException
- error access privilege informationNoSuchObjectException
- No such table existspublic List<String> listPartitionNamesPs(String catName, String dbName, String tableName, List<String> part_vals, short max_parts) throws MetaException, NoSuchObjectException
RawStore
listPartitionNamesPs
in interface RawStore
catName
- catalog name.dbName
- The name of the database which has the partitionstableName
- The name of the table which has the partitionspart_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 returnMetaException
- error accessing RDBMSNoSuchObjectException
- No such table existspublic List<Partition> getPartitionsByNames(String catName, String dbName, String tblName, List<String> partNames) throws MetaException, NoSuchObjectException
RawStore
getPartitionsByNames
in interface RawStore
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.MetaException
- error accessing the RDBMS.NoSuchObjectException
- No such table.protected List<Partition> getPartitionsByNamesInternal(String catName, String dbName, String tblName, List<String> partNames, boolean allowSql, boolean allowJdo) throws MetaException, NoSuchObjectException
MetaException
NoSuchObjectException
public boolean getPartitionsByExpr(String catName, String dbName, String tblName, byte[] expr, String defaultPartitionName, short maxParts, List<Partition> result) throws org.apache.thrift.TException
RawStore
getPartitionsByExpr
in interface RawStore
catName
- catalog name.dbName
- database nametblName
- table nameexpr
- an already parsed Hive expressiondefaultPartitionName
- default name of a partitionmaxParts
- maximum number of partitions to return, or -1 for allresult
- list to place resulting partitions inorg.apache.thrift.TException
- error executing the expressionprotected boolean getPartitionsByExprInternal(String catName, String dbName, String tblName, byte[] expr, String defaultPartitionName, short maxParts, List<Partition> result, boolean allowSql, boolean allowJdo) throws org.apache.thrift.TException
org.apache.thrift.TException
public List<Partition> getPartitionsByFilter(String catName, String dbName, String tblName, String filter, short maxParts) throws MetaException, NoSuchObjectException
RawStore
getPartitionsByFilter
in interface RawStore
catName
- catalog namedbName
- database nametblName
- table namefilter
- SQL where clause filtermaxParts
- maximum number of partitions to return, or -1 for all.MetaException
- Error accessing the RDBMS or processing the filter.NoSuchObjectException
- no such table.public int getNumPartitionsByFilter(String catName, String dbName, String tblName, String filter) throws MetaException, NoSuchObjectException
RawStore
getNumPartitionsByFilter
in interface RawStore
catName
- catalog name.dbName
- database name.tblName
- table name.filter
- filter from Hive's SQL where clauseMetaException
- error accessing the RDBMS or executing the filterNoSuchObjectException
- no such tablepublic int getNumPartitionsByExpr(String catName, String dbName, String tblName, byte[] expr) throws MetaException, NoSuchObjectException
RawStore
getNumPartitionsByExpr
in interface RawStore
catName
- catalog name.dbName
- database name.tblName
- table name.expr
- an already parsed Hive expressionMetaException
- error accessing the RDBMS or working with the expression.NoSuchObjectException
- no such table.protected List<Partition> getPartitionsByFilterInternal(String catName, String dbName, String tblName, String filter, short maxParts, boolean allowSql, boolean allowJdo) throws MetaException, NoSuchObjectException
MetaException
NoSuchObjectException
public List<String> listTableNamesByFilter(String catName, String dbName, String filter, short maxTables) throws MetaException
RawStore
listTableNamesByFilter
in interface RawStore
catName
- catalog namedbName
- The name of the database from which you will retrieve the table namesfilter
- The filter stringmaxTables
- The maximum number of tables returnedMetaException
public void alterTable(String catName, String dbname, String name, Table newTable) throws InvalidObjectException, MetaException
RawStore
alterTable
in interface RawStore
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.InvalidObjectException
- The new table object is invalid.MetaException
- something went wrong, usually in the RDBMS or storage.public void updateCreationMetadata(String catName, String dbname, String tablename, CreationMetadata cm) throws MetaException
RawStore
updateCreationMetadata
in interface RawStore
catName
- catalog name.dbname
- database name.tablename
- table name.cm
- new creation metadataMetaException
- error accessing the RDBMS.public void alterPartition(String catName, String dbname, String name, List<String> part_vals, Partition newPart) throws InvalidObjectException, MetaException
RawStore
alterPartition
in interface RawStore
catName
- catalog name.dbname
- database name.name
- table name.part_vals
- partition values that describe the partition.newPart
- new partition object. This should be a complete copy of the old with
changes values, not just the parts to update.InvalidObjectException
- No such partition.MetaException
- error accessing the RDBMS.public void alterPartitions(String catName, String dbname, String name, List<List<String>> part_vals, List<Partition> newParts) throws InvalidObjectException, MetaException
RawStore
alterPartitions
in interface RawStore
catName
- catalog name.dbname
- database name.name
- table name.part_vals
- list of list of partition values. Each outer list describes one
partition (with its list of partition values).newParts
- 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.InvalidObjectException
- One of the indicated partitions does not exist.MetaException
- error accessing the RDBMS.public List<String> addForeignKeys(List<SQLForeignKey> fks) throws InvalidObjectException, MetaException
RawStore
addForeignKeys
in interface RawStore
fks
- foreign key specificationInvalidObjectException
- the specification is malformed.MetaException
- error accessing the RDBMS.public String getMetastoreDbUuid() throws MetaException
RawStore
getMetastoreDbUuid
in interface RawStore
MetaException
public List<String> addPrimaryKeys(List<SQLPrimaryKey> pks) throws InvalidObjectException, MetaException
RawStore
addPrimaryKeys
in interface RawStore
pks
- Columns in the primary key.InvalidObjectException
- The SQLPrimaryKeys list is malformedMetaException
- error accessing the RDMBSpublic List<String> addUniqueConstraints(List<SQLUniqueConstraint> uks) throws InvalidObjectException, MetaException
RawStore
addUniqueConstraints
in interface RawStore
uks
- unique constraints specificationInvalidObjectException
- the specification is malformed.MetaException
- error accessing the RDBMS.public List<String> addNotNullConstraints(List<SQLNotNullConstraint> nns) throws InvalidObjectException, MetaException
RawStore
addNotNullConstraints
in interface RawStore
nns
- not null constraint specificationsInvalidObjectException
- the specification is malformed.MetaException
- error accessing the RDBMS.public List<String> addDefaultConstraints(List<SQLDefaultConstraint> nns) throws InvalidObjectException, MetaException
RawStore
addDefaultConstraints
in interface RawStore
nns
- list of default valuesInvalidObjectException
- the specification is malformed.MetaException
- error accessing the RDBMS.public List<String> addCheckConstraints(List<SQLCheckConstraint> nns) throws InvalidObjectException, MetaException
RawStore
addCheckConstraints
in interface RawStore
nns
- check constraints to addInvalidObjectException
- the specification is malformedMetaException
- error accessing the RDBMSpublic boolean addRole(String roleName, String ownerName) throws InvalidObjectException, MetaException, NoSuchObjectException
addRole
in interface RawStore
InvalidObjectException
MetaException
NoSuchObjectException
public boolean grantRole(Role role, String userName, PrincipalType principalType, String grantor, PrincipalType grantorType, boolean grantOption) throws MetaException, NoSuchObjectException, InvalidObjectException
grantRole
in interface RawStore
MetaException
NoSuchObjectException
InvalidObjectException
public boolean revokeRole(Role role, String userName, PrincipalType principalType, boolean grantOption) throws MetaException, NoSuchObjectException
revokeRole
in interface RawStore
MetaException
NoSuchObjectException
public boolean removeRole(String roleName) throws MetaException, NoSuchObjectException
removeRole
in interface RawStore
MetaException
NoSuchObjectException
public List<MRoleMap> listMRoles(String principalName, PrincipalType principalType)
public List<Role> listRoles(String principalName, PrincipalType principalType)
public List<RolePrincipalGrant> listRolesWithGrants(String principalName, PrincipalType principalType)
listRolesWithGrants
in interface RawStore
public Role getRole(String roleName) throws NoSuchObjectException
getRole
in interface RawStore
NoSuchObjectException
public List<String> listRoleNames()
listRoleNames
in interface RawStore
public PrincipalPrivilegeSet getUserPrivilegeSet(String userName, List<String> groupNames) throws InvalidObjectException, MetaException
getUserPrivilegeSet
in interface RawStore
InvalidObjectException
MetaException
public PrincipalPrivilegeSet getDBPrivilegeSet(String catName, String dbName, String userName, List<String> groupNames) throws InvalidObjectException, MetaException
RawStore
getDBPrivilegeSet
in interface RawStore
catName
- catalog namedbName
- database nameuserName
- user namegroupNames
- list of groups the user is inInvalidObjectException
- no such databaseMetaException
- error accessing the RDBMSpublic PrincipalPrivilegeSet getPartitionPrivilegeSet(String catName, String dbName, String tableName, String partition, String userName, List<String> groupNames) throws InvalidObjectException, MetaException
RawStore
getPartitionPrivilegeSet
in interface RawStore
catName
- catalog namedbName
- database nametableName
- table namepartition
- partition nameuserName
- user namegroupNames
- list of groups the user is inInvalidObjectException
- no such partitionMetaException
- error accessing the RDBMSpublic PrincipalPrivilegeSet getTablePrivilegeSet(String catName, String dbName, String tableName, String userName, List<String> groupNames) throws InvalidObjectException, MetaException
RawStore
getTablePrivilegeSet
in interface RawStore
catName
- catalog namedbName
- database nametableName
- table nameuserName
- user namegroupNames
- list of groups the user is inInvalidObjectException
- no such tableMetaException
- error accessing the RDBMSpublic PrincipalPrivilegeSet getColumnPrivilegeSet(String catName, String dbName, String tableName, String partitionName, String columnName, String userName, List<String> groupNames) throws InvalidObjectException, MetaException
RawStore
getColumnPrivilegeSet
in interface RawStore
catName
- catalog namedbName
- database nametableName
- table namepartitionName
- partition name, or null for table level column permissionscolumnName
- column nameuserName
- user namegroupNames
- list of groups the user is inInvalidObjectException
- no such table, partition, or columnMetaException
- error accessing the RDBMSpublic boolean grantPrivileges(PrivilegeBag privileges) throws InvalidObjectException, MetaException, NoSuchObjectException
grantPrivileges
in interface RawStore
InvalidObjectException
MetaException
NoSuchObjectException
public boolean revokePrivileges(PrivilegeBag privileges, boolean grantOption) throws InvalidObjectException, MetaException, NoSuchObjectException
revokePrivileges
in interface RawStore
InvalidObjectException
MetaException
NoSuchObjectException
public boolean refreshPrivileges(HiveObjectRef objToRefresh, String authorizer, PrivilegeBag grantPrivileges) throws InvalidObjectException, MetaException, NoSuchObjectException
refreshPrivileges
in interface RawStore
InvalidObjectException
MetaException
NoSuchObjectException
public List<RolePrincipalGrant> listRoleMembers(String roleName)
RawStore
listRoleMembers
in interface RawStore
public List<HiveObjectPrivilege> listPrincipalGlobalGrants(String principalName, PrincipalType principalType)
listPrincipalGlobalGrants
in interface RawStore
public List<HiveObjectPrivilege> listGlobalGrantsAll()
listGlobalGrantsAll
in interface RawStore
public List<HiveObjectPrivilege> listPrincipalDBGrants(String principalName, PrincipalType principalType, String catName, String dbName)
RawStore
listPrincipalDBGrants
in interface RawStore
principalName
- principal nameprincipalType
- typecatName
- catalog namedbName
- database namepublic List<HiveObjectPrivilege> listPrincipalDBGrantsAll(String principalName, PrincipalType principalType)
RawStore
listPrincipalDBGrantsAll
in interface RawStore
principalName
- principal nameprincipalType
- typepublic List<HiveObjectPrivilege> listDBGrantsAll(String catName, String dbName)
RawStore
listDBGrantsAll
in interface RawStore
catName
- catalog namedbName
- database namepublic List<HiveObjectPrivilege> listAllTableGrants(String principalName, PrincipalType principalType, String catName, String dbName, String tableName)
RawStore
listAllTableGrants
in interface RawStore
principalName
- principal nameprincipalType
- typecatName
- catalog namedbName
- database nametableName
- table namepublic List<HiveObjectPrivilege> listPrincipalPartitionGrants(String principalName, PrincipalType principalType, String catName, String dbName, String tableName, List<String> partValues, String partName)
RawStore
listPrincipalPartitionGrants
in interface RawStore
principalName
- principal nameprincipalType
- typecatName
- catalog namedbName
- database nametableName
- table namepartName
- partition name (not value)public List<HiveObjectPrivilege> listPrincipalTableColumnGrants(String principalName, PrincipalType principalType, String catName, String dbName, String tableName, String columnName)
RawStore
listPrincipalTableColumnGrants
in interface RawStore
principalName
- principal nameprincipalType
- typecatName
- catalog namedbName
- database nametableName
- table namecolumnName
- column namepublic List<HiveObjectPrivilege> listPrincipalPartitionColumnGrants(String principalName, PrincipalType principalType, String catName, String dbName, String tableName, List<String> partValues, String partitionName, String columnName)
RawStore
listPrincipalPartitionColumnGrants
in interface RawStore
principalName
- principal nameprincipalType
- typecatName
- catalog namedbName
- database nametableName
- table namepartitionName
- partition name (not value)columnName
- column namepublic List<HiveObjectPrivilege> listPrincipalPartitionColumnGrantsAll(String principalName, PrincipalType principalType)
RawStore
listPrincipalPartitionColumnGrantsAll
in interface RawStore
principalName
- principal nameprincipalType
- typepublic List<HiveObjectPrivilege> listPartitionColumnGrantsAll(String catName, String dbName, String tableName, String partitionName, String columnName)
RawStore
listPartitionColumnGrantsAll
in interface RawStore
catName
- catalog namedbName
- database nametableName
- table namepartitionName
- partition name (not value)columnName
- column namepublic List<HiveObjectPrivilege> listPrincipalTableGrantsAll(String principalName, PrincipalType principalType)
RawStore
listPrincipalTableGrantsAll
in interface RawStore
principalName
- principal nameprincipalType
- typepublic List<HiveObjectPrivilege> listTableGrantsAll(String catName, String dbName, String tableName)
RawStore
listTableGrantsAll
in interface RawStore
catName
- catalog namedbName
- database nametableName
- table namepublic List<HiveObjectPrivilege> listPrincipalPartitionGrantsAll(String principalName, PrincipalType principalType)
RawStore
listPrincipalPartitionGrantsAll
in interface RawStore
principalName
- principal nameprincipalType
- typepublic List<HiveObjectPrivilege> listPartitionGrantsAll(String catName, String dbName, String tableName, String partitionName)
RawStore
listPartitionGrantsAll
in interface RawStore
catName
- catalog namedbName
- database nametableName
- table namepartitionName
- partition name (not value)public List<HiveObjectPrivilege> listPrincipalTableColumnGrantsAll(String principalName, PrincipalType principalType)
RawStore
listPrincipalTableColumnGrantsAll
in interface RawStore
principalName
- principal nameprincipalType
- typepublic List<HiveObjectPrivilege> listTableColumnGrantsAll(String catName, String dbName, String tableName, String columnName)
RawStore
listTableColumnGrantsAll
in interface RawStore
catName
- catalog namedbName
- database nametableName
- table namecolumnName
- column namepublic boolean isPartitionMarkedForEvent(String catName, String dbName, String tblName, Map<String,String> partName, PartitionEventType evtType) throws UnknownTableException, MetaException, InvalidPartitionException, UnknownPartitionException
isPartitionMarkedForEvent
in interface RawStore
UnknownTableException
MetaException
InvalidPartitionException
UnknownPartitionException
public Table markPartitionForEvent(String catName, String dbName, String tblName, Map<String,String> partName, PartitionEventType evtType) throws MetaException, UnknownTableException, InvalidPartitionException, UnknownPartitionException
markPartitionForEvent
in interface RawStore
MetaException
UnknownTableException
InvalidPartitionException
UnknownPartitionException
public Collection<?> executeJDOQLSelect(String queryStr, ObjectStore.QueryWrapper queryWrapper)
public long executeJDOQLUpdate(String queryStr)
public Set<String> listFSRoots()
public ObjectStore.UpdateMDatabaseURIRetVal updateMDatabaseURI(URI oldLoc, URI newLoc, boolean dryRun)
public ObjectStore.UpdatePropURIRetVal updateTblPropURI(URI oldLoc, URI newLoc, String tblPropKey, boolean isDryRun)
@Deprecated public ObjectStore.UpdatePropURIRetVal updateMStorageDescriptorTblPropURI(URI oldLoc, URI newLoc, String tblPropKey, boolean isDryRun)
public ObjectStore.UpdateMStorageDescriptorTblURIRetVal updateMStorageDescriptorTblURI(URI oldLoc, URI newLoc, boolean isDryRun)
public ObjectStore.UpdateSerdeURIRetVal updateSerdeURI(URI oldLoc, URI newLoc, String serdeProp, boolean isDryRun)
public boolean updateTableColumnStatistics(ColumnStatistics colStats) throws NoSuchObjectException, MetaException, InvalidObjectException, InvalidInputException
RawStore
updateTableColumnStatistics
in interface RawStore
colStats
- object to persistNoSuchObjectException
- No such table.MetaException
- error accessing the RDBMS.InvalidObjectException
- the stats object is invalidInvalidInputException
- unable to record the stats for the tablepublic boolean updatePartitionColumnStatistics(ColumnStatistics colStats, List<String> partVals) throws NoSuchObjectException, MetaException, InvalidObjectException, InvalidInputException
RawStore
updatePartitionColumnStatistics
in interface RawStore
colStats
- object to persistpartVals
- partition values to persist the stats forNoSuchObjectException
- No such table.MetaException
- error accessing the RDBMS.InvalidObjectException
- the stats object is invalidInvalidInputException
- unable to record the stats for the tablepublic void validateTableCols(Table table, List<String> colNames) throws MetaException
MetaException
public ColumnStatistics getTableColumnStatistics(String catName, String dbName, String tableName, List<String> colNames) throws MetaException, NoSuchObjectException
RawStore
getTableColumnStatistics
in interface RawStore
catName
- catalog name.dbName
- name of the database, defaults to current databasetableName
- name of the tablecolNames
- names of the columns for which statistics is requestedMetaException
- error accessing the RDBMSNoSuchObjectException
- No such tableprotected ColumnStatistics getTableColumnStatisticsInternal(String catName, String dbName, String tableName, List<String> colNames, boolean allowSql, boolean allowJdo) throws MetaException, NoSuchObjectException
MetaException
NoSuchObjectException
public List<ColumnStatistics> getPartitionColumnStatistics(String catName, String dbName, String tableName, List<String> partNames, List<String> colNames) throws MetaException, NoSuchObjectException
RawStore
getPartitionColumnStatistics
in interface RawStore
catName
- catalog name.dbName
- database name.tableName
- table name.partNames
- list of partition names. These are names so must be key1=val1[/key2=val2...]colNames
- list of columns to get stats forMetaException
- error accessing the RDBMSNoSuchObjectException
- no such partition.protected List<ColumnStatistics> getPartitionColumnStatisticsInternal(String catName, String dbName, String tableName, List<String> partNames, List<String> colNames, boolean allowSql, boolean allowJdo) throws MetaException, NoSuchObjectException
MetaException
NoSuchObjectException
public AggrStats get_aggr_stats_for(String catName, String dbName, String tblName, List<String> partNames, List<String> colNames) throws MetaException, NoSuchObjectException
RawStore
get_aggr_stats_for
in interface RawStore
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 namesMetaException
- error accessing RDBMSNoSuchObjectException
- no such table or partitionpublic List<MetaStoreUtils.ColStatsObjWithSourceInfo> getPartitionColStatsForDatabase(String catName, String dbName) throws MetaException, NoSuchObjectException
RawStore
getPartitionColStatsForDatabase
in interface RawStore
catName
- catalog namedbName
- database nameMetaException
- error accessing RDBMSNoSuchObjectException
- no such databasepublic void flushCache()
flushCache
in interface RawStore
public boolean deletePartitionColumnStatistics(String catName, String dbName, String tableName, String partName, List<String> partVals, String colName) throws NoSuchObjectException, MetaException, InvalidObjectException, InvalidInputException
RawStore
deletePartitionColumnStatistics
in interface RawStore
catName
- catalog name.dbName
- database name.tableName
- table name.partName
- partition name.partVals
- partition values.colName
- column name.NoSuchObjectException
- no such partitionMetaException
- error access the RDBMSInvalidObjectException
- error dropping the statsInvalidInputException
- bad input, such as null table or database name.public boolean deleteTableColumnStatistics(String catName, String dbName, String tableName, String colName) throws NoSuchObjectException, MetaException, InvalidObjectException, InvalidInputException
RawStore
deleteTableColumnStatistics
in interface RawStore
catName
- catalog namedbName
- database nametableName
- table namecolName
- column name. Null to delete stats for all columns in the table.NoSuchObjectException
- no such table or column.MetaException
- error access the RDBMS.InvalidObjectException
- error dropping the statsInvalidInputException
- bad inputs, such as null table name.public long cleanupEvents()
cleanupEvents
in interface RawStore
public boolean removeToken(String tokenId)
removeToken
in interface RawStore
public List<String> getAllTokenIdentifiers()
getAllTokenIdentifiers
in interface RawStore
public int addMasterKey(String key) throws MetaException
addMasterKey
in interface RawStore
MetaException
public void updateMasterKey(Integer id, String key) throws NoSuchObjectException, MetaException
updateMasterKey
in interface RawStore
NoSuchObjectException
MetaException
public boolean removeMasterKey(Integer id)
removeMasterKey
in interface RawStore
public String[] getMasterKeys()
getMasterKeys
in interface RawStore
public void verifySchema() throws MetaException
verifySchema
in interface RawStore
MetaException
public static void setSchemaVerified(boolean val)
public String getMetaStoreSchemaVersion() throws MetaException
getMetaStoreSchemaVersion
in interface RawStore
MetaException
public void setMetaStoreSchemaVersion(String schemaVersion, String comment) throws MetaException
setMetaStoreSchemaVersion
in interface RawStore
MetaException
public boolean doesPartitionExist(String catName, String dbName, String tableName, List<String> partVals) throws MetaException
RawStore
doesPartitionExist
in interface RawStore
catName
- catalog name.dbName
- database name.tableName
- table name.partVals
- list of partition values.MetaException
- failure reading RDBMSpublic void createFunction(Function func) throws InvalidObjectException, MetaException
RawStore
createFunction
in interface RawStore
func
- function to createInvalidObjectException
- incorrectly specified functionMetaException
- error accessing the RDBMSpublic void alterFunction(String catName, String dbName, String funcName, Function newFunction) throws InvalidObjectException, MetaException
RawStore
alterFunction
in interface RawStore
dbName
- database namefuncName
- function namenewFunction
- new function specificationInvalidObjectException
- no such function, or incorrectly specified new functionMetaException
- incorrectly specified functionpublic void dropFunction(String catName, String dbName, String funcName) throws MetaException, NoSuchObjectException, InvalidObjectException, InvalidInputException
RawStore
dropFunction
in interface RawStore
dbName
- database namefuncName
- function nameMetaException
- incorrectly specified functionNoSuchObjectException
- no such functionInvalidObjectException
- not sure when this is thrownInvalidInputException
- not sure when this is thrownpublic Function getFunction(String catName, String dbName, String funcName) throws MetaException
RawStore
getFunction
in interface RawStore
dbName
- database namefuncName
- function nameMetaException
- incorrectly specified functionpublic List<Function> getAllFunctions(String catName) throws MetaException
RawStore
getAllFunctions
in interface RawStore
MetaException
- incorrectly specified functionpublic List<String> getFunctions(String catName, String dbName, String pattern) throws MetaException
RawStore
getFunctions
in interface RawStore
dbName
- database namepattern
- pattern to matchMetaException
- incorrectly specified functionpublic NotificationEventResponse getNextNotification(NotificationEventRequest rqst)
RawStore
getNextNotification
in interface RawStore
rqst
- Request containing information on the last processed notification.public void addNotificationEvent(NotificationEvent entry)
RawStore
addNotificationEvent
in interface RawStore
entry
- the notification to addpublic void cleanNotificationEvents(int olderThan)
RawStore
cleanNotificationEvents
in interface RawStore
olderThan
- Remove any events older than a given number of secondspublic CurrentNotificationEventId getCurrentNotificationEventId()
RawStore
getCurrentNotificationEventId
in interface RawStore
public NotificationEventsCountResponse getNotificationEventsCount(NotificationEventsCountRequest rqst)
RawStore
getNotificationEventsCount
in interface RawStore
public boolean isFileMetadataSupported()
isFileMetadataSupported
in interface RawStore
public ByteBuffer[] getFileMetadata(List<Long> fileIds)
getFileMetadata
in interface RawStore
fileIds
- List of file IDs from the filesystem.public void putFileMetadata(List<Long> fileIds, List<ByteBuffer> metadata, FileMetadataExprType type)
putFileMetadata
in interface RawStore
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.public void getFileMetadataByExpr(List<Long> fileIds, FileMetadataExprType type, byte[] expr, ByteBuffer[] metadatas, ByteBuffer[] stripeBitsets, boolean[] eliminated)
RawStore
getFileMetadataByExpr
in interface RawStore
fileIds
- List of file IDs from the filesystem.type
- Expression type; used to determine the class that handles the metadata.expr
- Format-specific serialized expression applicable to the files' metadatas.metadatas
- Output parameter; fileIds-sized array to receive the metadatas
for corresponding files, if any.stripeBitsets
- 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.public FileMetadataHandler getFileMetadataHandler(FileMetadataExprType type)
RawStore
getFileMetadataHandler
in interface RawStore
public static void unCacheDataNucleusClassLoaders()
public List<SQLPrimaryKey> getPrimaryKeys(String catName, String db_name, String tbl_name) throws MetaException
RawStore
getPrimaryKeys
in interface RawStore
catName
- catalog namedb_name
- database nametbl_name
- table nameMetaException
- error accessing the RDBMSpublic List<SQLForeignKey> getForeignKeys(String catName, String parent_db_name, String parent_tbl_name, String foreign_db_name, String foreign_tbl_name) throws MetaException
RawStore
getForeignKeys
in interface RawStore
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.MetaException
- error access the RDBMS.public List<SQLUniqueConstraint> getUniqueConstraints(String catName, String db_name, String tbl_name) throws MetaException
RawStore
getUniqueConstraints
in interface RawStore
catName
- catalog name.db_name
- database name.tbl_name
- table name.MetaException
- error access the RDBMS.public List<SQLNotNullConstraint> getNotNullConstraints(String catName, String db_name, String tbl_name) throws MetaException
RawStore
getNotNullConstraints
in interface RawStore
catName
- catalog name.db_name
- database name.tbl_name
- table name.MetaException
- error accessing the RDBMS.public List<SQLDefaultConstraint> getDefaultConstraints(String catName, String db_name, String tbl_name) throws MetaException
RawStore
getDefaultConstraints
in interface RawStore
catName
- catalog namedb_name
- database nametbl_name
- table nameMetaException
- error accessing the RDBMSpublic List<SQLCheckConstraint> getCheckConstraints(String catName, String db_name, String tbl_name) throws MetaException
RawStore
getCheckConstraints
in interface RawStore
catName
- catalog name.db_name
- database nametbl_name
- table nameMetaException
- error accessing the RDBMSprotected List<SQLCheckConstraint> getCheckConstraintsInternal(String catName, String db_name_input, String tbl_name_input, boolean allowSql, boolean allowJdo) throws MetaException, NoSuchObjectException
MetaException
NoSuchObjectException
protected List<SQLNotNullConstraint> getNotNullConstraintsInternal(String catName, String db_name_input, String tbl_name_input, boolean allowSql, boolean allowJdo) throws MetaException, NoSuchObjectException
MetaException
NoSuchObjectException
public void dropConstraint(String catName, String dbName, String tableName, String constraintName, boolean missingOk) throws NoSuchObjectException
RawStore
dropConstraint
in interface RawStore
catName
- catalog namedbName
- database nametableName
- table nameconstraintName
- name of the constraintmissingOk
- 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.NoSuchObjectException
- no constraint of this name exists and missingOk = falsepublic void createISchema(ISchema schema) throws AlreadyExistsException, MetaException, NoSuchObjectException
RawStore
createISchema
in interface RawStore
schema
- schema to createAlreadyExistsException
- there's already a schema with this nameMetaException
- general database exceptionNoSuchObjectException
public void alterISchema(ISchemaName schemaName, ISchema newSchema) throws NoSuchObjectException, MetaException
RawStore
alterISchema
in interface RawStore
schemaName
- name of the schemanewSchema
- new schema objectNoSuchObjectException
- no function with this name existsMetaException
- general database exceptionpublic ISchema getISchema(ISchemaName schemaName) throws MetaException
RawStore
getISchema
in interface RawStore
schemaName
- schema descriptorMetaException
- general database exceptionpublic void dropISchema(ISchemaName schemaName) throws NoSuchObjectException, MetaException
RawStore
dropISchema
in interface RawStore
schemaName
- schema descriptorNoSuchObjectException
- no schema of this name existsMetaException
- general database exceptionpublic void addSchemaVersion(SchemaVersion schemaVersion) throws AlreadyExistsException, NoSuchObjectException, MetaException
RawStore
addSchemaVersion
in interface RawStore
schemaVersion
- version numberAlreadyExistsException
- a version of the schema with the same version number already
exists.NoSuchObjectException
- no schema with the passed in name exists.MetaException
- general database exceptionpublic void alterSchemaVersion(SchemaVersionDescriptor version, SchemaVersion newVersion) throws NoSuchObjectException, MetaException
RawStore
alterSchemaVersion
in interface RawStore
version
- version descriptor for the schemanewVersion
- altered SchemaVersionNoSuchObjectException
- no such version of the named schema existsMetaException
- general database exceptionpublic SchemaVersion getSchemaVersion(SchemaVersionDescriptor version) throws MetaException
RawStore
getSchemaVersion
in interface RawStore
version
- version descriptor for the schemaMetaException
- general database exceptionpublic SchemaVersion getLatestSchemaVersion(ISchemaName schemaName) throws MetaException
RawStore
getLatestSchemaVersion
in interface RawStore
schemaName
- name of the schemaMetaException
- general database exceptionpublic List<SchemaVersion> getAllSchemaVersion(ISchemaName schemaName) throws MetaException
RawStore
getAllSchemaVersion
in interface RawStore
schemaName
- name of the schemaMetaException
- general database exceptionpublic List<SchemaVersion> getSchemaVersionsByColumns(String colName, String colNamespace, String type) throws MetaException
RawStore
getSchemaVersionsByColumns
in interface RawStore
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.MetaException
- general database exceptionpublic void dropSchemaVersion(SchemaVersionDescriptor version) throws NoSuchObjectException, MetaException
RawStore
dropSchemaVersion
in interface RawStore
version
- version descriptor for the schemaNoSuchObjectException
- no such version of the named schema existsMetaException
- general database exceptionpublic SerDeInfo getSerDeInfo(String serDeName) throws NoSuchObjectException, MetaException
RawStore
getSerDeInfo
in interface RawStore
serDeName
- name of the SerDeNoSuchObjectException
- no serde with this name existsMetaException
- general database exceptionpublic void addSerde(SerDeInfo serde) throws AlreadyExistsException, MetaException
RawStore
addSerde
in interface RawStore
serde
- serde to addAlreadyExistsException
- a serde of this name already existsMetaException
- general database exceptionpublic static void setTwoMetastoreTesting(boolean twoMetastoreTesting)
twoMetastoreTesting
- if we are using multiple metastore in unit testpublic void createResourcePlan(WMResourcePlan resourcePlan, String copyFromName, int defaultPoolSize) throws AlreadyExistsException, InvalidObjectException, MetaException, NoSuchObjectException
createResourcePlan
in interface RawStore
AlreadyExistsException
InvalidObjectException
MetaException
NoSuchObjectException
public WMFullResourcePlan getResourcePlan(String name) throws NoSuchObjectException
getResourcePlan
in interface RawStore
NoSuchObjectException
public List<WMResourcePlan> getAllResourcePlans() throws MetaException
getAllResourcePlans
in interface RawStore
MetaException
public WMFullResourcePlan alterResourcePlan(String name, WMNullableResourcePlan changes, boolean canActivateDisabled, boolean canDeactivate, boolean isReplace) throws AlreadyExistsException, NoSuchObjectException, InvalidOperationException, MetaException
alterResourcePlan
in interface RawStore
AlreadyExistsException
NoSuchObjectException
InvalidOperationException
MetaException
public WMFullResourcePlan getActiveResourcePlan() throws MetaException
getActiveResourcePlan
in interface RawStore
MetaException
public WMValidateResourcePlanResponse validateResourcePlan(String name) throws NoSuchObjectException, InvalidObjectException, MetaException
validateResourcePlan
in interface RawStore
NoSuchObjectException
InvalidObjectException
MetaException
public void dropResourcePlan(String name) throws NoSuchObjectException, MetaException
dropResourcePlan
in interface RawStore
NoSuchObjectException
MetaException
public void createWMTrigger(WMTrigger trigger) throws AlreadyExistsException, NoSuchObjectException, InvalidOperationException, MetaException
createWMTrigger
in interface RawStore
AlreadyExistsException
NoSuchObjectException
InvalidOperationException
MetaException
public void alterWMTrigger(WMTrigger trigger) throws NoSuchObjectException, InvalidOperationException, MetaException
alterWMTrigger
in interface RawStore
NoSuchObjectException
InvalidOperationException
MetaException
public void dropWMTrigger(String resourcePlanName, String triggerName) throws NoSuchObjectException, InvalidOperationException, MetaException
dropWMTrigger
in interface RawStore
NoSuchObjectException
InvalidOperationException
MetaException
public List<WMTrigger> getTriggersForResourcePlan(String resourcePlanName) throws NoSuchObjectException, MetaException
getTriggersForResourcePlan
in interface RawStore
NoSuchObjectException
MetaException
public void createPool(WMPool pool) throws AlreadyExistsException, NoSuchObjectException, InvalidOperationException, MetaException
createPool
in interface RawStore
AlreadyExistsException
NoSuchObjectException
InvalidOperationException
MetaException
public void alterPool(WMNullablePool pool, String poolPath) throws AlreadyExistsException, NoSuchObjectException, InvalidOperationException, MetaException
alterPool
in interface RawStore
AlreadyExistsException
NoSuchObjectException
InvalidOperationException
MetaException
public void dropWMPool(String resourcePlanName, String poolPath) throws NoSuchObjectException, InvalidOperationException, MetaException
dropWMPool
in interface RawStore
NoSuchObjectException
InvalidOperationException
MetaException
public void createOrUpdateWMMapping(WMMapping mapping, boolean update) throws AlreadyExistsException, NoSuchObjectException, InvalidOperationException, MetaException
createOrUpdateWMMapping
in interface RawStore
AlreadyExistsException
NoSuchObjectException
InvalidOperationException
MetaException
public void dropWMMapping(WMMapping mapping) throws NoSuchObjectException, InvalidOperationException, MetaException
dropWMMapping
in interface RawStore
NoSuchObjectException
InvalidOperationException
MetaException
public void createWMTriggerToPoolMapping(String resourcePlanName, String triggerName, String poolPath) throws AlreadyExistsException, NoSuchObjectException, InvalidOperationException, MetaException
createWMTriggerToPoolMapping
in interface RawStore
AlreadyExistsException
NoSuchObjectException
InvalidOperationException
MetaException
public void dropWMTriggerToPoolMapping(String resourcePlanName, String triggerName, String poolPath) throws NoSuchObjectException, InvalidOperationException, MetaException
dropWMTriggerToPoolMapping
in interface RawStore
NoSuchObjectException
InvalidOperationException
MetaException
public void addRuntimeStat(RuntimeStat stat) throws MetaException
RawStore
addRuntimeStat
in interface RawStore
MetaException
public int deleteRuntimeStats(int maxRetainSecs) throws MetaException
RawStore
deleteRuntimeStats
in interface RawStore
MetaException
public List<RuntimeStat> getRuntimeStats(int maxEntries, int maxCreateTime) throws MetaException
RawStore
getRuntimeStats
in interface RawStore
MetaException
Copyright © 2022 The Apache Software Foundation. All rights reserved.