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
InvalidObjectExceptionMetaExceptionDatabase getDatabase(java.lang.String name) throws NoSuchObjectException
NoSuchObjectExceptionboolean dropDatabase(java.lang.String dbname)
throws NoSuchObjectException,
MetaException
NoSuchObjectExceptionMetaExceptionboolean alterDatabase(java.lang.String dbname,
Database db)
throws NoSuchObjectException,
MetaException
NoSuchObjectExceptionMetaExceptionjava.util.List<java.lang.String> getDatabases(java.lang.String pattern)
throws MetaException
MetaExceptionjava.util.List<java.lang.String> getAllDatabases()
throws MetaException
MetaExceptionboolean createType(Type type)
Type getType(java.lang.String typeName)
boolean dropType(java.lang.String typeName)
void createTable(Table tbl) throws InvalidObjectException, MetaException
InvalidObjectExceptionMetaExceptionboolean 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
MetaExceptionboolean addPartition(Partition part) throws InvalidObjectException, MetaException
InvalidObjectExceptionMetaExceptionPartition getPartition(java.lang.String dbName, java.lang.String tableName, java.util.List<java.lang.String> part_vals) throws MetaException, NoSuchObjectException
MetaExceptionNoSuchObjectExceptionboolean 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
MetaExceptionvoid alterTable(java.lang.String dbname,
java.lang.String name,
Table newTable)
throws InvalidObjectException,
MetaException
InvalidObjectExceptionMetaExceptionjava.util.List<java.lang.String> getTables(java.lang.String dbName,
java.lang.String pattern)
throws MetaException
MetaExceptionjava.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.MetaExceptionUnknownDBExceptionjava.util.List<java.lang.String> getAllTables(java.lang.String dbName)
throws MetaException
MetaExceptionjava.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 returnedMetaExceptionUnknownDBExceptionjava.util.List<java.lang.String> listPartitionNames(java.lang.String db_name,
java.lang.String tbl_name,
short max_parts)
throws MetaException
MetaExceptionjava.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
MetaExceptionvoid 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
InvalidObjectExceptionMetaExceptionvoid 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
InvalidObjectExceptionMetaExceptionboolean addIndex(Index index) throws InvalidObjectException, MetaException
InvalidObjectExceptionMetaExceptionIndex getIndex(java.lang.String dbName, java.lang.String origTableName, java.lang.String indexName) throws MetaException
MetaExceptionboolean dropIndex(java.lang.String dbName,
java.lang.String origTableName,
java.lang.String indexName)
throws MetaException
MetaExceptionjava.util.List<Index> getIndexes(java.lang.String dbName, java.lang.String origTableName, int max) throws MetaException
MetaExceptionjava.util.List<java.lang.String> listIndexNames(java.lang.String dbName,
java.lang.String origTableName,
short max)
throws MetaException
MetaExceptionvoid alterIndex(java.lang.String dbname,
java.lang.String baseTblName,
java.lang.String name,
Index newIndex)
throws InvalidObjectException,
MetaException
InvalidObjectExceptionMetaExceptionjava.util.List<Partition> getPartitionsByFilter(java.lang.String dbName, java.lang.String tblName, java.lang.String filter, short maxParts) throws MetaException, NoSuchObjectException
MetaExceptionNoSuchObjectExceptionjava.util.List<Partition> getPartitionsByNames(java.lang.String dbName, java.lang.String tblName, java.util.List<java.lang.String> partNames) throws MetaException, NoSuchObjectException
MetaExceptionNoSuchObjectExceptionTable 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
MetaExceptionNoSuchObjectExceptionboolean 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
MetaExceptionNoSuchObjectExceptionPrincipalPrivilegeSet getUserPrivilegeSet(java.lang.String userName, java.util.List<java.lang.String> groupNames) throws InvalidObjectException, MetaException
InvalidObjectExceptionMetaExceptionPrincipalPrivilegeSet getDBPrivilegeSet(java.lang.String dbName, java.lang.String userName, java.util.List<java.lang.String> groupNames) throws InvalidObjectException, MetaException
InvalidObjectExceptionMetaExceptionPrincipalPrivilegeSet getTablePrivilegeSet(java.lang.String dbName, java.lang.String tableName, java.lang.String userName, java.util.List<java.lang.String> groupNames) throws InvalidObjectException, MetaException
InvalidObjectExceptionMetaExceptionPrincipalPrivilegeSet 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
InvalidObjectExceptionMetaExceptionPrincipalPrivilegeSet 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
InvalidObjectExceptionMetaExceptionjava.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
NoSuchObjectExceptionjava.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 returnMetaExceptionNoSuchObjectExceptionjava.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 privilegesMetaExceptionNoSuchObjectExceptionInvalidObjectExceptionboolean updateTableColumnStatistics(ColumnStatistics colStats) throws NoSuchObjectException, MetaException, InvalidObjectException, InvalidInputException
partVals - ColumnStats - object to persistList - of partValsNoSuchObjectExceptionMetaExceptionInvalidObjectExceptionInvalidInputExceptionboolean updatePartitionColumnStatistics(ColumnStatistics statsObj, java.util.List<java.lang.String> partVals) throws NoSuchObjectException, MetaException, InvalidObjectException, InvalidInputException
partVals - ColumnStats - object to persistList - of partValsNoSuchObjectExceptionMetaExceptionInvalidObjectExceptionInvalidInputExceptionColumnStatistics 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 requestedNoSuchObjectExceptionMetaExceptionInvalidInputExceptionInvalidObjectExceptionColumnStatistics 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 requestedNoSuchObjectExceptionMetaExceptionInvalidInputExceptionInvalidObjectExceptionboolean 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 - NoSuchObjectExceptionMetaExceptionInvalidObjectExceptionInvalidInputExceptionboolean deleteTableColumnStatistics(java.lang.String dbName,
java.lang.String tableName,
java.lang.String colName)
throws NoSuchObjectException,
MetaException,
InvalidObjectException,
InvalidInputException
dbName - tableName - colName - NoSuchObjectExceptionMetaExceptionInvalidObjectExceptionInvalidInputExceptionlong 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
MetaExceptionvoid updateMasterKey(java.lang.Integer seqNo,
java.lang.String key)
throws NoSuchObjectException,
MetaException
NoSuchObjectExceptionMetaExceptionboolean removeMasterKey(java.lang.Integer keySeq)
java.lang.String[] getMasterKeys()
void verifySchema()
throws MetaException
MetaExceptionjava.lang.String getMetaStoreSchemaVersion()
throws MetaException
MetaExceptionvoid setMetaStoreSchemaVersion(java.lang.String version,
java.lang.String comment)
throws MetaException
MetaExceptionCopyright © 2012 The Apache Software Foundation