public interface RawStore
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 rowName,
java.lang.String ownerName) |
boolean |
addToken(java.lang.String tokenIdentifier,
java.lang.String delegationToken) |
boolean |
alterDatabase(java.lang.String dbname,
Database db) |
void |
alterIndex(java.lang.String dbname,
java.lang.String baseTblName,
java.lang.String name,
Index newIndex) |
void |
alterPartition(java.lang.String db_name,
java.lang.String tbl_name,
java.util.List<java.lang.String> part_vals,
Partition new_part) |
void |
alterPartitions(java.lang.String db_name,
java.lang.String tbl_name,
java.util.List<java.util.List<java.lang.String>> part_vals_list,
java.util.List<Partition> new_parts) |
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.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) |
Database |
getDatabase(java.lang.String name) |
java.util.List<java.lang.String> |
getDatabases(java.lang.String pattern) |
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> partVals,
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 max) |
java.util.List<Partition> |
getPartitionsByFilter(java.lang.String dbName,
java.lang.String tblName,
java.lang.String filter,
short maxParts) |
java.util.List<Partition> |
getPartitionsByNames(java.lang.String dbName,
java.lang.String tblName,
java.util.List<java.lang.String> partNames) |
java.util.List<Partition> |
getPartitionsWithAuth(java.lang.String dbName,
java.lang.String tblName,
short maxParts,
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) |
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 dbname,
java.util.List<java.lang.String> tableNames) |
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 tokenIdentifier) |
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 |
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<java.lang.String> |
listIndexNames(java.lang.String dbName,
java.lang.String origTableName,
short max) |
java.util.List<java.lang.String> |
listPartitionNames(java.lang.String db_name,
java.lang.String tbl_name,
short max_parts) |
java.util.List<java.lang.String> |
listPartitionNamesByFilter(java.lang.String db_name,
java.lang.String tbl_name,
java.lang.String filter,
short max_parts) |
java.util.List<java.lang.String> |
listPartitionNamesPs(java.lang.String db_name,
java.lang.String tbl_name,
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 partName,
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<java.lang.String> |
listTableNamesByFilter(java.lang.String dbName,
java.lang.String filter,
short max_tables)
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> partVals,
PartitionEventType evtType) |
boolean |
openTransaction()
Opens a new one or the one already created Every call of this function must
have corresponding commit or rollback function call
|
boolean |
removeMasterKey(java.lang.Integer keySeq) |
boolean |
removeRole(java.lang.String roleName) |
boolean |
removeToken(java.lang.String tokenIdentifier) |
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 |
setMetaStoreSchemaVersion(java.lang.String version,
java.lang.String comment) |
void |
shutdown() |
void |
updateMasterKey(java.lang.Integer seqNo,
java.lang.String key) |
boolean |
updatePartitionColumnStatistics(ColumnStatistics statsObj,
java.util.List<java.lang.String> partVals)
Persists the given column statistics object to the metastore
|
boolean |
updateTableColumnStatistics(ColumnStatistics colStats)
Persists the given column statistics object to the metastore
|
void |
verifySchema() |
void shutdown()
boolean openTransaction()
boolean commitTransaction()
void rollbackTransaction()
void createDatabase(Database db) throws InvalidObjectException, MetaException
InvalidObjectException
MetaException
Database getDatabase(java.lang.String name) throws NoSuchObjectException
NoSuchObjectException
boolean dropDatabase(java.lang.String dbname) throws NoSuchObjectException, MetaException
NoSuchObjectException
MetaException
boolean alterDatabase(java.lang.String dbname, Database db) throws NoSuchObjectException, MetaException
NoSuchObjectException
MetaException
java.util.List<java.lang.String> getDatabases(java.lang.String pattern) throws MetaException
MetaException
java.util.List<java.lang.String> getAllDatabases() throws MetaException
MetaException
boolean createType(Type type)
Type getType(java.lang.String typeName)
boolean dropType(java.lang.String typeName)
void createTable(Table tbl) throws InvalidObjectException, MetaException
InvalidObjectException
MetaException
boolean dropTable(java.lang.String dbName, java.lang.String tableName) throws MetaException, NoSuchObjectException, InvalidObjectException, InvalidInputException
Table getTable(java.lang.String dbName, java.lang.String tableName) throws MetaException
MetaException
boolean addPartition(Partition part) throws InvalidObjectException, MetaException
InvalidObjectException
MetaException
Partition getPartition(java.lang.String dbName, java.lang.String tableName, java.util.List<java.lang.String> part_vals) throws MetaException, NoSuchObjectException
MetaException
NoSuchObjectException
boolean dropPartition(java.lang.String dbName, java.lang.String tableName, java.util.List<java.lang.String> part_vals) throws MetaException, NoSuchObjectException, InvalidObjectException, InvalidInputException
java.util.List<Partition> getPartitions(java.lang.String dbName, java.lang.String tableName, int max) throws MetaException
MetaException
void alterTable(java.lang.String dbname, java.lang.String name, Table newTable) throws InvalidObjectException, MetaException
InvalidObjectException
MetaException
java.util.List<java.lang.String> getTables(java.lang.String dbName, java.lang.String pattern) throws MetaException
MetaException
java.util.List<Table> getTableObjectsByName(java.lang.String dbname, java.util.List<java.lang.String> tableNames) throws MetaException, UnknownDBException
dbname
- The name of the database from which to retrieve the tablestableNames
- The names of the tables to retrieve.MetaException
UnknownDBException
java.util.List<java.lang.String> getAllTables(java.lang.String dbName) throws MetaException
MetaException
java.util.List<java.lang.String> listTableNamesByFilter(java.lang.String dbName, java.lang.String filter, short max_tables) throws MetaException, UnknownDBException
dbName
- The name of the database from which you will retrieve the table namesfilter
- The filter stringmax_tables
- The maximum number of tables returnedMetaException
UnknownDBException
java.util.List<java.lang.String> listPartitionNames(java.lang.String db_name, java.lang.String tbl_name, short max_parts) throws MetaException
MetaException
java.util.List<java.lang.String> listPartitionNamesByFilter(java.lang.String db_name, java.lang.String tbl_name, java.lang.String filter, short max_parts) throws MetaException
MetaException
void alterPartition(java.lang.String db_name, java.lang.String tbl_name, java.util.List<java.lang.String> part_vals, Partition new_part) throws InvalidObjectException, MetaException
InvalidObjectException
MetaException
void alterPartitions(java.lang.String db_name, java.lang.String tbl_name, java.util.List<java.util.List<java.lang.String>> part_vals_list, java.util.List<Partition> new_parts) throws InvalidObjectException, MetaException
InvalidObjectException
MetaException
boolean addIndex(Index index) throws InvalidObjectException, MetaException
InvalidObjectException
MetaException
Index getIndex(java.lang.String dbName, java.lang.String origTableName, java.lang.String indexName) throws MetaException
MetaException
boolean dropIndex(java.lang.String dbName, java.lang.String origTableName, java.lang.String indexName) throws MetaException
MetaException
java.util.List<Index> getIndexes(java.lang.String dbName, java.lang.String origTableName, int max) throws MetaException
MetaException
java.util.List<java.lang.String> listIndexNames(java.lang.String dbName, java.lang.String origTableName, short max) throws MetaException
MetaException
void alterIndex(java.lang.String dbname, java.lang.String baseTblName, java.lang.String name, Index newIndex) throws InvalidObjectException, MetaException
InvalidObjectException
MetaException
java.util.List<Partition> getPartitionsByFilter(java.lang.String dbName, java.lang.String tblName, java.lang.String filter, short maxParts) throws MetaException, NoSuchObjectException
MetaException
NoSuchObjectException
java.util.List<Partition> getPartitionsByNames(java.lang.String dbName, java.lang.String tblName, java.util.List<java.lang.String> partNames) throws MetaException, NoSuchObjectException
MetaException
NoSuchObjectException
Table markPartitionForEvent(java.lang.String dbName, java.lang.String tblName, java.util.Map<java.lang.String,java.lang.String> partVals, PartitionEventType evtType) throws MetaException, UnknownTableException, InvalidPartitionException, UnknownPartitionException
boolean isPartitionMarkedForEvent(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
boolean addRole(java.lang.String rowName, java.lang.String ownerName) throws InvalidObjectException, MetaException, NoSuchObjectException
boolean removeRole(java.lang.String roleName) throws MetaException, NoSuchObjectException
MetaException
NoSuchObjectException
boolean grantRole(Role role, java.lang.String userName, PrincipalType principalType, java.lang.String grantor, PrincipalType grantorType, boolean grantOption) throws MetaException, NoSuchObjectException, InvalidObjectException
boolean revokeRole(Role role, java.lang.String userName, PrincipalType principalType) throws MetaException, NoSuchObjectException
MetaException
NoSuchObjectException
PrincipalPrivilegeSet getUserPrivilegeSet(java.lang.String userName, java.util.List<java.lang.String> groupNames) throws InvalidObjectException, MetaException
InvalidObjectException
MetaException
PrincipalPrivilegeSet getDBPrivilegeSet(java.lang.String dbName, java.lang.String userName, java.util.List<java.lang.String> groupNames) throws InvalidObjectException, MetaException
InvalidObjectException
MetaException
PrincipalPrivilegeSet getTablePrivilegeSet(java.lang.String dbName, java.lang.String tableName, java.lang.String userName, java.util.List<java.lang.String> groupNames) throws InvalidObjectException, MetaException
InvalidObjectException
MetaException
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
InvalidObjectException
MetaException
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
InvalidObjectException
MetaException
java.util.List<MGlobalPrivilege> listPrincipalGlobalGrants(java.lang.String principalName, PrincipalType principalType)
java.util.List<MDBPrivilege> listPrincipalDBGrants(java.lang.String principalName, PrincipalType principalType, java.lang.String dbName)
java.util.List<MTablePrivilege> listAllTableGrants(java.lang.String principalName, PrincipalType principalType, java.lang.String dbName, java.lang.String tableName)
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<MPartitionColumnPrivilege> listPrincipalPartitionColumnGrants(java.lang.String principalName, PrincipalType principalType, java.lang.String dbName, java.lang.String tableName, java.lang.String partName, java.lang.String columnName)
boolean grantPrivileges(PrivilegeBag privileges) throws InvalidObjectException, MetaException, NoSuchObjectException
boolean revokePrivileges(PrivilegeBag privileges) throws InvalidObjectException, MetaException, NoSuchObjectException
Role getRole(java.lang.String roleName) throws NoSuchObjectException
NoSuchObjectException
java.util.List<java.lang.String> listRoleNames()
java.util.List<MRoleMap> listRoles(java.lang.String principalName, PrincipalType principalType)
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 MetaException, NoSuchObjectException, InvalidObjectException
java.util.List<Partition> getPartitionsWithAuth(java.lang.String dbName, java.lang.String tblName, short maxParts, java.lang.String userName, java.util.List<java.lang.String> groupNames) throws MetaException, NoSuchObjectException, InvalidObjectException
java.util.List<java.lang.String> listPartitionNamesPs(java.lang.String db_name, java.lang.String tbl_name, java.util.List<java.lang.String> part_vals, short max_parts) throws MetaException, NoSuchObjectException
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 only want to specify latter partitions.max_parts
- The maximum number of partitions to returnMetaException
NoSuchObjectException
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
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
NoSuchObjectException
InvalidObjectException
boolean updateTableColumnStatistics(ColumnStatistics colStats) throws NoSuchObjectException, MetaException, InvalidObjectException, InvalidInputException
partVals
- ColumnStats
- object to persistList
- of partValsNoSuchObjectException
MetaException
InvalidObjectException
InvalidInputException
boolean updatePartitionColumnStatistics(ColumnStatistics statsObj, java.util.List<java.lang.String> partVals) throws NoSuchObjectException, MetaException, InvalidObjectException, InvalidInputException
partVals
- ColumnStats
- object to persistList
- of partValsNoSuchObjectException
MetaException
InvalidObjectException
InvalidInputException
ColumnStatistics getTableColumnStatistics(java.lang.String dbName, java.lang.String tableName, java.lang.String colName) throws MetaException, NoSuchObjectException, InvalidInputException, InvalidObjectException
The
- name of the database, defaults to current databaseThe
- name of the tableThe
- name of the column for which statistics is requestedNoSuchObjectException
MetaException
InvalidInputException
InvalidObjectException
ColumnStatistics getPartitionColumnStatistics(java.lang.String dbName, java.lang.String tableName, java.lang.String partName, java.util.List<java.lang.String> partVals, java.lang.String colName) throws MetaException, NoSuchObjectException, InvalidInputException, InvalidObjectException
partName
- The
- name of the database, defaults to current databaseThe
- name of the tableThe
- name of the partitionList
- of partVals for the partitionThe
- name of the column for which statistics is requestedNoSuchObjectException
MetaException
InvalidInputException
InvalidObjectException
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
dbName
- tableName
- partName
- partVals
- colName
- NoSuchObjectException
MetaException
InvalidObjectException
InvalidInputException
boolean deleteTableColumnStatistics(java.lang.String dbName, java.lang.String tableName, java.lang.String colName) throws NoSuchObjectException, MetaException, InvalidObjectException, InvalidInputException
dbName
- tableName
- colName
- NoSuchObjectException
MetaException
InvalidObjectException
InvalidInputException
long cleanupEvents()
boolean addToken(java.lang.String tokenIdentifier, java.lang.String delegationToken)
boolean removeToken(java.lang.String tokenIdentifier)
java.lang.String getToken(java.lang.String tokenIdentifier)
java.util.List<java.lang.String> getAllTokenIdentifiers()
int addMasterKey(java.lang.String key) throws MetaException
MetaException
void updateMasterKey(java.lang.Integer seqNo, java.lang.String key) throws NoSuchObjectException, MetaException
NoSuchObjectException
MetaException
boolean removeMasterKey(java.lang.Integer keySeq)
java.lang.String[] getMasterKeys()
void verifySchema() throws MetaException
MetaException
java.lang.String getMetaStoreSchemaVersion() throws MetaException
MetaException
void setMetaStoreSchemaVersion(java.lang.String version, java.lang.String comment) throws MetaException
MetaException
Copyright © 2012 The Apache Software Foundation