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