@InterfaceAudience.Public
@InterfaceStability.Evolving
public interface IMetaStoreClient
Modifier and Type | Interface and Description |
---|---|
static class |
IMetaStoreClient.IncompatibleMetastoreException |
static interface |
IMetaStoreClient.NotificationFilter
A filter provided by the client that determines if a given notification event should be
returned.
|
Modifier and Type | Method and Description |
---|---|
void |
abortTxns(List<Long> txnids)
Abort a list of transactions.
|
Partition |
add_partition(Partition partition)
Add a partition to the table.
|
int |
add_partitions_pspec(PartitionSpecProxy partitionSpec)
Add a partitions using a spec proxy.
|
int |
add_partitions(List<Partition> partitions)
Add partitions to the table.
|
List<Partition> |
add_partitions(List<Partition> partitions,
boolean ifNotExists,
boolean needResults)
Add partitions to the table.
|
void |
addCheckConstraint(List<SQLCheckConstraint> checkConstraints) |
void |
addDefaultConstraint(List<SQLDefaultConstraint> defaultConstraints) |
void |
addDynamicPartitions(long txnId,
long writeId,
String dbName,
String tableName,
List<String> partNames)
Deprecated.
in Hive 1.3.0/2.1.0 - will be removed in 2 releases
|
void |
addDynamicPartitions(long txnId,
long writeId,
String dbName,
String tableName,
List<String> partNames,
DataOperationType operationType)
Send a list of partitions to the metastore to indicate which partitions were loaded
dynamically.
|
void |
addForeignKey(List<SQLForeignKey> foreignKeyCols)
Add a foreign key
|
int |
addMasterKey(String key) |
void |
addNotNullConstraint(List<SQLNotNullConstraint> notNullConstraintCols)
Add a not null constraint
|
void |
addPrimaryKey(List<SQLPrimaryKey> primaryKeyCols)
Add a primary key.
|
void |
addRuntimeStat(RuntimeStat stat)
Adds a RuntimeStat for metastore persistence.
|
void |
addSchemaVersion(SchemaVersion schemaVersion)
Add a new version to an existing schema.
|
void |
addSerDe(SerDeInfo serDeInfo)
Add a serde.
|
boolean |
addToken(String tokenIdentifier,
String delegationToken) |
void |
addUniqueConstraint(List<SQLUniqueConstraint> uniqueConstraintCols)
Add a unique constraint
|
long |
allocateTableWriteId(long txnId,
String dbName,
String tableName)
Allocate a per table write ID and associate it with the given transaction.
|
List<TxnToWriteId> |
allocateTableWriteIdsBatch(List<Long> txnIds,
String dbName,
String tableName)
Allocate a per table write ID and associate it with the given transaction.
|
void |
alter_partition(String dbName,
String tblName,
Partition newPart)
updates a partition to new partition
|
void |
alter_partition(String dbName,
String tblName,
Partition newPart,
EnvironmentContext environmentContext)
updates a partition to new partition
|
default void |
alter_partition(String catName,
String dbName,
String tblName,
Partition newPart)
updates a partition to new partition
|
void |
alter_partition(String catName,
String dbName,
String tblName,
Partition newPart,
EnvironmentContext environmentContext)
updates a partition to new partition
|
void |
alter_partitions(String dbName,
String tblName,
List<Partition> newParts)
updates a list of partitions
|
void |
alter_partitions(String dbName,
String tblName,
List<Partition> newParts,
EnvironmentContext environmentContext)
updates a list of partitions
|
default void |
alter_partitions(String catName,
String dbName,
String tblName,
List<Partition> newParts)
updates a list of partitions
|
void |
alter_partitions(String catName,
String dbName,
String tblName,
List<Partition> newParts,
EnvironmentContext environmentContext)
updates a list of partitions
|
void |
alter_table_with_environmentContext(String databaseName,
String tblName,
Table table,
EnvironmentContext environmentContext)
Alter a table.
|
default void |
alter_table(String catName,
String dbName,
String tblName,
Table newTable)
Alter a table.
|
void |
alter_table(String catName,
String dbName,
String tblName,
Table newTable,
EnvironmentContext envContext)
Alter a table.
|
void |
alter_table(String databaseName,
String tblName,
Table table)
Alter a table
|
void |
alter_table(String defaultDatabaseName,
String tblName,
Table table,
boolean cascade)
Deprecated.
Use alter_table_with_environmentContext instead of alter_table with cascade option
passed in EnvironmentContext using
StatsSetupConst.CASCADE |
void |
alterCatalog(String catalogName,
Catalog newCatalog)
Alter an existing catalog.
|
void |
alterDatabase(String name,
Database db)
Alter a database.
|
void |
alterDatabase(String catName,
String dbName,
Database newDb)
Alter a database.
|
void |
alterFunction(String dbName,
String funcName,
Function newFunction)
Alter a function.
|
void |
alterFunction(String catName,
String dbName,
String funcName,
Function newFunction)
Alter a function.
|
void |
alterISchema(String catName,
String dbName,
String schemaName,
ISchema newSchema)
Alter an existing schema.
|
WMFullResourcePlan |
alterResourcePlan(String resourcePlanName,
WMNullableResourcePlan resourcePlan,
boolean canActivateDisabled,
boolean isForceDeactivate,
boolean isReplace) |
void |
alterWMPool(WMNullablePool pool,
String poolPath) |
void |
alterWMTrigger(WMTrigger trigger) |
Partition |
appendPartition(String dbName,
String tableName,
List<String> partVals)
/**
Add a partition to a table and get back the resulting Partition object.
|
Partition |
appendPartition(String dbName,
String tableName,
String name)
Add a partition to a table and get back the resulting Partition object.
|
Partition |
appendPartition(String catName,
String dbName,
String tableName,
List<String> partVals)
Add a partition to a table and get back the resulting Partition object.
|
Partition |
appendPartition(String catName,
String dbName,
String tableName,
String name)
Add a partition to a table and get back the resulting Partition object.
|
boolean |
cacheFileMetadata(String dbName,
String tableName,
String partName,
boolean allParts) |
void |
cancelDelegationToken(String tokenStrForm) |
LockResponse |
checkLock(long lockid)
Check the status of a set of locks requested via a
lock(org.apache.hadoop.hive.metastore.api.LockRequest) call. |
void |
clearFileMetadata(List<Long> fileIds)
Cleares the file metadata cache for respective file IDs.
|
void |
close()
close connection to meta store
|
void |
commitTxn(long txnid)
Commit a transaction.
|
void |
compact(String dbname,
String tableName,
String partitionName,
CompactionType type)
Deprecated.
|
void |
compact(String dbname,
String tableName,
String partitionName,
CompactionType type,
Map<String,String> tblproperties)
Deprecated.
|
CompactionResponse |
compact2(String dbname,
String tableName,
String partitionName,
CompactionType type,
Map<String,String> tblproperties)
Send a request to compact a table or partition.
|
boolean |
create_role(Role role) |
void |
createCatalog(Catalog catalog)
Create a new catalog.
|
void |
createDatabase(Database db)
Create a new database.
|
void |
createFunction(Function func)
Create a new function.
|
void |
createISchema(ISchema schema)
Create a new schema.
|
void |
createOrDropTriggerToPoolMapping(String resourcePlanName,
String triggerName,
String poolPath,
boolean shouldDrop) |
void |
createOrUpdateWMMapping(WMMapping mapping,
boolean isUpdate) |
void |
createResourcePlan(WMResourcePlan resourcePlan,
String copyFromName) |
void |
createTable(Table tbl) |
void |
createTableWithConstraints(Table tTbl,
List<SQLPrimaryKey> primaryKeys,
List<SQLForeignKey> foreignKeys,
List<SQLUniqueConstraint> uniqueConstraints,
List<SQLNotNullConstraint> notNullConstraints,
List<SQLDefaultConstraint> defaultConstraints,
List<SQLCheckConstraint> checkConstraints) |
void |
createWMPool(WMPool pool) |
void |
createWMTrigger(WMTrigger trigger) |
boolean |
deletePartitionColumnStatistics(String dbName,
String tableName,
String partName,
String colName)
Delete partition level column statistics given dbName, tableName, partName and colName, or
all columns in a partition.
|
boolean |
deletePartitionColumnStatistics(String catName,
String dbName,
String tableName,
String partName,
String colName)
Delete partition level column statistics given dbName, tableName, partName and colName, or
all columns in a partition.
|
boolean |
deleteTableColumnStatistics(String dbName,
String tableName,
String colName)
Delete table level column statistics given dbName, tableName and colName, or all columns in
a table.
|
boolean |
deleteTableColumnStatistics(String catName,
String dbName,
String tableName,
String colName)
Delete table level column statistics given dbName, tableName and colName, or all columns in
a table.
|
boolean |
drop_role(String role_name) |
void |
dropCatalog(String catName)
Drop a catalog.
|
void |
dropConstraint(String dbName,
String tableName,
String constraintName)
Drop a constraint.
|
void |
dropConstraint(String catName,
String dbName,
String tableName,
String constraintName)
Drop a constraint.
|
void |
dropDatabase(String name)
Drop a database.
|
void |
dropDatabase(String name,
boolean deleteData,
boolean ignoreUnknownDb)
Drop a database.
|
void |
dropDatabase(String name,
boolean deleteData,
boolean ignoreUnknownDb,
boolean cascade)
Drop a database.
|
default void |
dropDatabase(String catName,
String dbName)
Drop a database.
|
default void |
dropDatabase(String catName,
String dbName,
boolean deleteData,
boolean ignoreUnknownDb)
Drop a database.
|
void |
dropDatabase(String catName,
String dbName,
boolean deleteData,
boolean ignoreUnknownDb,
boolean cascade)
Drop a database.
|
void |
dropFunction(String dbName,
String funcName)
Drop a function.
|
void |
dropFunction(String catName,
String dbName,
String funcName)
Drop a function.
|
void |
dropISchema(String catName,
String dbName,
String name)
Drop an existing schema.
|
boolean |
dropPartition(String db_name,
String tbl_name,
List<String> part_vals,
boolean deleteData)
Drop a partition.
|
boolean |
dropPartition(String db_name,
String tbl_name,
List<String> part_vals,
PartitionDropOptions options)
Drop a partition with the option to purge the partition data directly,
rather than to move data to trash.
|
boolean |
dropPartition(String db_name,
String tbl_name,
String name,
boolean deleteData)
Drop a partition.
|
boolean |
dropPartition(String catName,
String db_name,
String tbl_name,
List<String> part_vals,
boolean deleteData)
Drop a partition.
|
boolean |
dropPartition(String catName,
String db_name,
String tbl_name,
List<String> part_vals,
PartitionDropOptions options)
Drop a partition with the option to purge the partition data directly,
rather than to move data to trash.
|
boolean |
dropPartition(String catName,
String db_name,
String tbl_name,
String name,
boolean deleteData)
Drop a partition.
|
List<Partition> |
dropPartitions(String dbName,
String tblName,
List<ObjectPair<Integer,byte[]>> partExprs,
boolean deleteData,
boolean ifExists)
Drop partitions based on an expression.
|
List<Partition> |
dropPartitions(String dbName,
String tblName,
List<ObjectPair<Integer,byte[]>> partExprs,
boolean deleteData,
boolean ifExists,
boolean needResults)
|
List<Partition> |
dropPartitions(String dbName,
String tblName,
List<ObjectPair<Integer,byte[]>> partExprs,
PartitionDropOptions options)
Generalization of dropPartitions(),
|
default List<Partition> |
dropPartitions(String catName,
String dbName,
String tblName,
List<ObjectPair<Integer,byte[]>> partExprs,
boolean deleteData,
boolean ifExists)
Drop partitions based on an expression.
|
default List<Partition> |
dropPartitions(String catName,
String dbName,
String tblName,
List<ObjectPair<Integer,byte[]>> partExprs,
boolean deleteData,
boolean ifExists,
boolean needResults)
Drop partitions based on an expression.
|
List<Partition> |
dropPartitions(String catName,
String dbName,
String tblName,
List<ObjectPair<Integer,byte[]>> partExprs,
PartitionDropOptions options)
Generalization of dropPartitions(),
|
void |
dropResourcePlan(String resourcePlanName) |
void |
dropSchemaVersion(String catName,
String dbName,
String schemaName,
int version)
Drop a version of a schema.
|
void |
dropTable(String dbname,
String tableName)
Drop the table.
|
void |
dropTable(String dbname,
String tableName,
boolean deleteData,
boolean ignoreUnknownTab)
Drop the table.
|
void |
dropTable(String dbname,
String tableName,
boolean deleteData,
boolean ignoreUnknownTab,
boolean ifPurge)
Drop the table.
|
default void |
dropTable(String catName,
String dbName,
String tableName)
Drop a table.
|
default void |
dropTable(String catName,
String dbName,
String tableName,
boolean deleteData,
boolean ignoreUnknownTable)
Drop a table.
|
void |
dropTable(String catName,
String dbName,
String tableName,
boolean deleteData,
boolean ignoreUnknownTable,
boolean ifPurge)
Drop a table.
|
void |
dropWMMapping(WMMapping mapping) |
void |
dropWMPool(String resourcePlanName,
String poolPath) |
void |
dropWMTrigger(String resourcePlanName,
String triggerName) |
Partition |
exchange_partition(Map<String,String> partitionSpecs,
String sourceDb,
String sourceTable,
String destdb,
String destTableName)
Move a partition from one table to another
|
Partition |
exchange_partition(Map<String,String> partitionSpecs,
String sourceCat,
String sourceDb,
String sourceTable,
String destCat,
String destdb,
String destTableName)
Move a partition from one table to another
|
List<Partition> |
exchange_partitions(Map<String,String> partitionSpecs,
String sourceDb,
String sourceTable,
String destdb,
String destTableName)
With the one partitionSpecs to exchange, multiple partitions could be exchanged.
|
List<Partition> |
exchange_partitions(Map<String,String> partitionSpecs,
String sourceCat,
String sourceDb,
String sourceTable,
String destCat,
String destdb,
String destTableName)
With the one partitionSpecs to exchange, multiple partitions could be exchanged.
|
FireEventResponse |
fireListenerEvent(FireEventRequest request)
Request that the metastore fire an event.
|
void |
flushCache()
Flush any catalog objects held by the metastore implementation.
|
GetPrincipalsInRoleResponse |
get_principals_in_role(GetPrincipalsInRoleRequest getPrincRoleReq)
get all role-grants for users/roles that have been granted the given role
Note that in the returned list of RolePrincipalGrants, the roleName is
redundant as it would match the role_name argument of this function
|
PrincipalPrivilegeSet |
get_privilege_set(HiveObjectRef hiveObject,
String user_name,
List<String> group_names)
Return the privileges that the user, group have directly and indirectly through roles
on the given hiveObject
|
GetRoleGrantsForPrincipalResponse |
get_role_grants_for_principal(GetRoleGrantsForPrincipalRequest getRolePrincReq)
get all role-grants for roles that have been granted to given principal
Note that in the returned list of RolePrincipalGrants, the principal information
redundant as it would match the principal information in request
|
WMFullResourcePlan |
getActiveResourcePlan() |
AggrStats |
getAggrColStatsFor(String dbName,
String tblName,
List<String> colNames,
List<String> partName)
Get aggregated column stats for a set of partitions.
|
AggrStats |
getAggrColStatsFor(String catName,
String dbName,
String tblName,
List<String> colNames,
List<String> partNames)
Get aggregated column stats for a set of partitions.
|
List<String> |
getAllDatabases()
Get the names of all databases in the MetaStore.
|
List<String> |
getAllDatabases(String catName)
Get all databases in a catalog.
|
GetAllFunctionsResponse |
getAllFunctions()
Get all functions in the default catalog.
|
List<WMResourcePlan> |
getAllResourcePlans() |
List<String> |
getAllTables(String dbName)
Get the names of all tables in the specified database.
|
List<String> |
getAllTables(String catName,
String dbName)
Get the names of all tables in the specified database.
|
List<String> |
getAllTokenIdentifiers() |
Catalog |
getCatalog(String catName)
Get a catalog object.
|
List<String> |
getCatalogs()
Get a list of all catalogs known to the system.
|
List<SQLCheckConstraint> |
getCheckConstraints(CheckConstraintsRequest request) |
String |
getConfigValue(String name,
String defaultValue) |
CurrentNotificationEventId |
getCurrentNotificationEventId()
Get the last used notification event id.
|
Database |
getDatabase(String databaseName)
Get a Database Object in the default catalog
|
Database |
getDatabase(String catalogName,
String databaseName)
Get a database.
|
List<String> |
getDatabases(String databasePattern)
Get the names of all databases in the default catalog that match the given pattern.
|
List<String> |
getDatabases(String catName,
String databasePattern)
Get all databases in a catalog whose names match a pattern.
|
List<SQLDefaultConstraint> |
getDefaultConstraints(DefaultConstraintsRequest request) |
String |
getDelegationToken(String owner,
String renewerKerberosPrincipalName)
This is expected to be a no-op when in local mode,
which means that the implementation will return null.
|
List<FieldSchema> |
getFields(String db,
String tableName)
Get schema for a table, excluding the partition columns.
|
List<FieldSchema> |
getFields(String catName,
String db,
String tableName)
Get schema for a table, excluding the partition columns.
|
Iterable<Map.Entry<Long,ByteBuffer>> |
getFileMetadata(List<Long> fileIds)
Gets file metadata, as cached by metastore, for respective file IDs.
|
Iterable<Map.Entry<Long,MetadataPpdResult>> |
getFileMetadataBySarg(List<Long> fileIds,
ByteBuffer sarg,
boolean doGetFooters) |
List<SQLForeignKey> |
getForeignKeys(ForeignKeysRequest request)
Get a foreign key for a table.
|
Function |
getFunction(String dbName,
String funcName)
Get a function.
|
Function |
getFunction(String catName,
String dbName,
String funcName)
Get a function.
|
List<String> |
getFunctions(String dbName,
String pattern)
Get all functions matching a pattern
|
List<String> |
getFunctions(String catName,
String dbName,
String pattern)
Get all functions matching a pattern
|
ISchema |
getISchema(String catName,
String dbName,
String name)
Fetch a schema.
|
String[] |
getMasterKeys() |
Materialization |
getMaterializationInvalidationInfo(CreationMetadata cm,
String validTxnList)
Returns the invalidation information for the materialized views given as input.
|
List<String> |
getMaterializedViewsForRewriting(String dbName)
Get materialized views that have rewriting enabled.
|
List<String> |
getMaterializedViewsForRewriting(String catName,
String dbName)
Get materialized views that have rewriting enabled.
|
String |
getMetaConf(String key)
get current meta variable
|
String |
getMetastoreDbUuid()
Gets the unique id of the backing database instance used for storing metadata
|
NotificationEventResponse |
getNextNotification(long lastEventId,
int maxEvents,
IMetaStoreClient.NotificationFilter filter)
Get the next set of notifications from the database.
|
NotificationEventsCountResponse |
getNotificationEventsCount(NotificationEventsCountRequest rqst)
Get the number of events from given eventID for the input database.
|
List<SQLNotNullConstraint> |
getNotNullConstraints(NotNullConstraintsRequest request)
Get a not null constraint for a table.
|
int |
getNumPartitionsByFilter(String dbName,
String tableName,
String filter)
Get number of partitions matching specified filter
|
int |
getNumPartitionsByFilter(String catName,
String dbName,
String tableName,
String filter)
Get number of partitions matching specified filter
|
Partition |
getPartition(String dbName,
String tblName,
List<String> partVals)
Get a partition.
|
Partition |
getPartition(String dbName,
String tblName,
String name)
Get a Partition by name.
|
Partition |
getPartition(String catName,
String dbName,
String tblName,
List<String> partVals)
Get a partition.
|
Partition |
getPartition(String catName,
String dbName,
String tblName,
String name)
Get a Partition by name.
|
Map<String,List<ColumnStatisticsObj>> |
getPartitionColumnStatistics(String dbName,
String tableName,
List<String> partNames,
List<String> colNames)
Get the column statistics for a set of columns in a partition.
|
Map<String,List<ColumnStatisticsObj>> |
getPartitionColumnStatistics(String catName,
String dbName,
String tableName,
List<String> partNames,
List<String> colNames)
Get the column statistics for a set of columns in a partition.
|
List<Partition> |
getPartitionsByNames(String db_name,
String tbl_name,
List<String> part_names)
Get partitions by a list of partition names.
|
List<Partition> |
getPartitionsByNames(String catName,
String db_name,
String tbl_name,
List<String> part_names)
Get partitions by a list of partition names.
|
Partition |
getPartitionWithAuthInfo(String dbName,
String tableName,
List<String> pvals,
String userName,
List<String> groupNames)
Get a Partition along with authorization information.
|
Partition |
getPartitionWithAuthInfo(String catName,
String dbName,
String tableName,
List<String> pvals,
String userName,
List<String> groupNames)
Get a Partition along with authorization information.
|
List<SQLPrimaryKey> |
getPrimaryKeys(PrimaryKeysRequest request)
Get a primary key for a table.
|
WMFullResourcePlan |
getResourcePlan(String resourcePlanName) |
List<RuntimeStat> |
getRuntimeStats(int maxWeight,
int maxCreateTime)
Reads runtime statistics.
|
List<FieldSchema> |
getSchema(String db,
String tableName)
Get schema for a table, including the partition columns.
|
List<FieldSchema> |
getSchema(String catName,
String db,
String tableName)
Get schema for a table, including the partition columns.
|
List<SchemaVersion> |
getSchemaAllVersions(String catName,
String dbName,
String schemaName)
Get all the extant versions of a schema.
|
FindSchemasByColsResp |
getSchemaByCols(FindSchemasByColsRqst rqst)
Find all schema versions that have columns that match a query.
|
SchemaVersion |
getSchemaLatestVersion(String catName,
String dbName,
String schemaName)
Get the latest version of a schema.
|
SchemaVersion |
getSchemaVersion(String catName,
String dbName,
String schemaName,
int version)
Get a specific version of a schema.
|
SerDeInfo |
getSerDe(String serDeName)
Fetch a serde.
|
Table |
getTable(String dbName,
String tableName)
Get a table object in the default catalog.
|
Table |
getTable(String catName,
String dbName,
String tableName)
Get a table object.
|
List<ColumnStatisticsObj> |
getTableColumnStatistics(String dbName,
String tableName,
List<String> colNames)
Get the column statistics for a set of columns in a table.
|
List<ColumnStatisticsObj> |
getTableColumnStatistics(String catName,
String dbName,
String tableName,
List<String> colNames)
Get the column statistics for a set of columns in a table.
|
List<TableMeta> |
getTableMeta(String dbPatterns,
String tablePatterns,
List<String> tableTypes)
Fetches just table name and comments.
|
List<TableMeta> |
getTableMeta(String catName,
String dbPatterns,
String tablePatterns,
List<String> tableTypes)
Fetches just table name and comments.
|
List<Table> |
getTableObjectsByName(String dbName,
List<String> tableNames)
Get tables as objects (rather than just fetching their names).
|
List<Table> |
getTableObjectsByName(String catName,
String dbName,
List<String> tableNames)
Get tables as objects (rather than just fetching their names).
|
List<String> |
getTables(String dbName,
String tablePattern)
Get the names of all tables in the specified database that satisfy the supplied
table name pattern.
|
List<String> |
getTables(String catName,
String dbName,
String tablePattern)
Get the names of all tables in the specified database that satisfy the supplied
table name pattern.
|
List<String> |
getTables(String catName,
String dbName,
String tablePattern,
TableType tableType)
Get the names of all tables in the specified database that satisfy the supplied
table name pattern and table type (MANAGED_TABLE || EXTERNAL_TABLE || VIRTUAL_VIEW)
|
List<String> |
getTables(String dbName,
String tablePattern,
TableType tableType)
Get the names of all tables in the specified database that satisfy the supplied
table name pattern and table type (MANAGED_TABLE || EXTERNAL_TABLE || VIRTUAL_VIEW)
|
String |
getToken(String tokenIdentifier) |
String |
getTokenStrForm() |
List<WMTrigger> |
getTriggersForResourcePlan(String resourcePlan) |
List<SQLUniqueConstraint> |
getUniqueConstraints(UniqueConstraintsRequest request)
Get a unique constraint for a table.
|
org.apache.hadoop.hive.common.ValidTxnList |
getValidTxns()
Get a structure that details valid transactions.
|
org.apache.hadoop.hive.common.ValidTxnList |
getValidTxns(long currentTxn)
Get a structure that details valid transactions.
|
List<TableValidWriteIds> |
getValidWriteIds(List<String> tablesList,
String validTxnList)
Get a structure that details valid write ids list for all tables read by current txn.
|
org.apache.hadoop.hive.common.ValidWriteIdList |
getValidWriteIds(String fullTableName)
Get a structure that details valid transactions.
|
boolean |
grant_privileges(PrivilegeBag privileges) |
boolean |
grant_role(String role_name,
String user_name,
PrincipalType principalType,
String grantor,
PrincipalType grantorType,
boolean grantOption) |
void |
heartbeat(long txnid,
long lockid)
Send a heartbeat to indicate that the client holding these locks (if
any) and that opened this transaction (if one exists) is still alive.
|
boolean |
heartbeatLockMaterializationRebuild(String dbName,
String tableName,
long txnId)
Method to refresh the acquisition of a given materialization rebuild lock.
|
HeartbeatTxnRangeResponse |
heartbeatTxnRange(long min,
long max)
Send heartbeats for a range of transactions.
|
void |
insertTable(Table table,
boolean overwrite)
Performs the commit/rollback to the metadata storage for insert operator from external storage handler.
|
boolean |
isCompatibleWith(org.apache.hadoop.conf.Configuration conf)
Returns whether current client is compatible with conf argument or not
|
boolean |
isLocalMetaStore()
Returns true if the current client is using an in process metastore (local metastore).
|
boolean |
isPartitionMarkedForEvent(String db_name,
String tbl_name,
Map<String,String> partKVs,
PartitionEventType eventType)
Determine whether a partition has been marked with a particular event type.
|
boolean |
isPartitionMarkedForEvent(String catName,
String db_name,
String tbl_name,
Map<String,String> partKVs,
PartitionEventType eventType)
Determine whether a partition has been marked with a particular event type.
|
boolean |
isSameConfObj(org.apache.hadoop.conf.Configuration c) |
List<HiveObjectPrivilege> |
list_privileges(String principal_name,
PrincipalType principal_type,
HiveObjectRef hiveObject)
Return the privileges that this principal has directly over the object (not through roles).
|
List<Role> |
list_roles(String principalName,
PrincipalType principalType) |
List<String> |
listPartitionNames(String db_name,
String tbl_name,
List<String> part_vals,
short max_parts)
Get a list of partition names matching a partial specification of the partition values.
|
List<String> |
listPartitionNames(String db_name,
String tbl_name,
short max_parts)
List Names of partitions in a table.
|
List<String> |
listPartitionNames(String catName,
String db_name,
String tbl_name,
int max_parts)
List Names of partitions in a table.
|
List<String> |
listPartitionNames(String catName,
String db_name,
String tbl_name,
List<String> part_vals,
int max_parts)
Get a list of partition names matching a partial specification of the partition values.
|
List<Partition> |
listPartitions(String db_name,
String tbl_name,
List<String> part_vals,
short max_parts)
Get a list of partitions based on a (possibly partial) list of partition values.
|
List<Partition> |
listPartitions(String db_name,
String tbl_name,
short max_parts)
Get a list of partittions for a table.
|
List<Partition> |
listPartitions(String catName,
String db_name,
String tbl_name,
int max_parts)
Get a list of partittions for a table.
|
List<Partition> |
listPartitions(String catName,
String db_name,
String tbl_name,
List<String> part_vals,
int max_parts)
Get a list of partitions based on a (possibly partial) list of partition values.
|
boolean |
listPartitionsByExpr(String db_name,
String tbl_name,
byte[] expr,
String default_partition_name,
short max_parts,
List<Partition> result)
Get list of partitions matching specified serialized expression
|
boolean |
listPartitionsByExpr(String catName,
String db_name,
String tbl_name,
byte[] expr,
String default_partition_name,
int max_parts,
List<Partition> result)
Get list of partitions matching specified serialized expression
|
List<Partition> |
listPartitionsByFilter(String db_name,
String tbl_name,
String filter,
short max_parts)
Get list of partitions matching specified filter
|
List<Partition> |
listPartitionsByFilter(String catName,
String db_name,
String tbl_name,
String filter,
int max_parts)
Get list of partitions matching specified filter
|
PartitionSpecProxy |
listPartitionSpecs(String dbName,
String tableName,
int maxParts)
Get a list of partitions from a table, returned in the form of PartitionSpecProxy
|
PartitionSpecProxy |
listPartitionSpecs(String catName,
String dbName,
String tableName,
int maxParts)
Get a list of partitions from a table, returned in the form of PartitionSpecProxy
|
PartitionSpecProxy |
listPartitionSpecsByFilter(String db_name,
String tbl_name,
String filter,
int max_parts)
Get a list of partitions in a PartitionSpec, using a filter to select which partitions to
fetch.
|
PartitionSpecProxy |
listPartitionSpecsByFilter(String catName,
String db_name,
String tbl_name,
String filter,
int max_parts)
Get a list of partitions in a PartitionSpec, using a filter to select which partitions to
fetch.
|
List<Partition> |
listPartitionsWithAuthInfo(String dbName,
String tableName,
List<String> partialPvals,
short maxParts,
String userName,
List<String> groupNames)
List partitions along with privilege information for a user or groups
|
List<Partition> |
listPartitionsWithAuthInfo(String dbName,
String tableName,
short maxParts,
String userName,
List<String> groupNames)
List partitions, fetching the authorization information along with the partitions.
|
List<Partition> |
listPartitionsWithAuthInfo(String catName,
String dbName,
String tableName,
int maxParts,
String userName,
List<String> groupNames)
List partitions, fetching the authorization information along with the partitions.
|
List<Partition> |
listPartitionsWithAuthInfo(String catName,
String dbName,
String tableName,
List<String> partialPvals,
int maxParts,
String userName,
List<String> groupNames)
List partitions along with privilege information for a user or groups
|
PartitionValuesResponse |
listPartitionValues(PartitionValuesRequest request)
Get a list of partition values
|
List<String> |
listRoleNames()
list all role names
|
List<String> |
listTableNamesByFilter(String dbName,
String filter,
short maxTables)
Get a list of table names that match a filter.
|
List<String> |
listTableNamesByFilter(String catName,
String dbName,
String filter,
int maxTables)
Get a list of table names that match a filter.
|
LockResponse |
lock(LockRequest request)
Request a set of locks.
|
LockResponse |
lockMaterializationRebuild(String dbName,
String tableName,
long txnId)
Acquire the materialization rebuild lock for a given view.
|
void |
mapSchemaVersionToSerde(String catName,
String dbName,
String schemaName,
int version,
String serdeName)
Map a schema version to a serde.
|
void |
markPartitionForEvent(String db_name,
String tbl_name,
Map<String,String> partKVs,
PartitionEventType eventType)
Mark an event as having occurred on a partition.
|
void |
markPartitionForEvent(String catName,
String db_name,
String tbl_name,
Map<String,String> partKVs,
PartitionEventType eventType)
Mark an event as having occurred on a partition.
|
long |
openTxn(String user)
Initiate a transaction.
|
OpenTxnsResponse |
openTxns(String user,
int numTxns)
Initiate a batch of transactions.
|
Map<String,String> |
partitionNameToSpec(String name) |
List<String> |
partitionNameToVals(String name) |
void |
putFileMetadata(List<Long> fileIds,
List<ByteBuffer> metadata)
Adds file metadata for respective file IDs to metadata cache in metastore.
|
void |
reconnect()
Tries to reconnect this MetaStoreClient to the MetaStore.
|
CmRecycleResponse |
recycleDirToCmPath(CmRecycleRequest request)
Recycles the files recursively from the input path to the cmroot directory either by copying or moving it.
|
boolean |
refresh_privileges(HiveObjectRef objToRefresh,
String authorizer,
PrivilegeBag grantPrivileges) |
boolean |
removeMasterKey(Integer keySeq) |
boolean |
removeToken(String tokenIdentifier) |
void |
renamePartition(String dbname,
String tableName,
List<String> part_vals,
Partition newPart)
rename a partition to a new partition
|
void |
renamePartition(String catName,
String dbname,
String tableName,
List<String> part_vals,
Partition newPart)
rename a partition to a new partition
|
long |
renewDelegationToken(String tokenStrForm) |
List<TxnToWriteId> |
replAllocateTableWriteIdsBatch(String dbName,
String tableName,
String replPolicy,
List<TxnToWriteId> srcTxnToWriteIdList)
Allocate a per table write ID and associate it with the given transaction.
|
void |
replCommitTxn(long srcTxnid,
String replPolicy)
Commit a transaction.
|
List<Long> |
replOpenTxn(String replPolicy,
List<Long> srcTxnIds,
String user)
Initiate a transaction at the target cluster.
|
void |
replRollbackTxn(long srcTxnid,
String replPolicy)
Rollback a transaction.
|
void |
replTableWriteIdState(String validWriteIdList,
String dbName,
String tableName,
List<String> partNames)
Replicate Table Write Ids state to mark aborted write ids and writeid high water mark.
|
boolean |
revoke_privileges(PrivilegeBag privileges,
boolean grantOption) |
boolean |
revoke_role(String role_name,
String user_name,
PrincipalType principalType,
boolean grantOption) |
void |
rollbackTxn(long txnid)
Rollback a transaction.
|
void |
setHiveAddedJars(String addedJars)
Set added jars path info to MetaStoreClient.
|
void |
setMetaConf(String key,
String value)
set meta variable which is open to end users
|
boolean |
setPartitionColumnStatistics(SetPartitionsStatsRequest request)
Set table or partition column statistics.
|
void |
setSchemaVersionState(String catName,
String dbName,
String schemaName,
int version,
SchemaVersionState state)
Set the state of a schema version.
|
ShowCompactResponse |
showCompactions()
Get a list of all compactions.
|
ShowLocksResponse |
showLocks()
Deprecated.
|
ShowLocksResponse |
showLocks(ShowLocksRequest showLocksRequest)
Show all currently held and waiting locks.
|
GetOpenTxnsInfoResponse |
showTxns()
Show the list of currently open transactions.
|
boolean |
tableExists(String databaseName,
String tableName)
Check whether a table exists in the default catalog.
|
boolean |
tableExists(String catName,
String dbName,
String tableName)
Check whether a table exists.
|
void |
truncateTable(String dbName,
String tableName,
List<String> partNames)
Truncate the table/partitions in the DEFAULT database.
|
void |
truncateTable(String catName,
String dbName,
String tableName,
List<String> partNames)
Truncate the table/partitions in the DEFAULT database.
|
void |
unlock(long lockid)
Unlock a set of locks.
|
void |
updateCreationMetadata(String dbName,
String tableName,
CreationMetadata cm)
Updates the creation metadata for the materialized view.
|
void |
updateCreationMetadata(String catName,
String dbName,
String tableName,
CreationMetadata cm)
Updates the creation metadata for the materialized view.
|
void |
updateMasterKey(Integer seqNo,
String key) |
boolean |
updatePartitionColumnStatistics(ColumnStatistics statsObj)
Write partition level column statistics to persistent store
|
boolean |
updateTableColumnStatistics(ColumnStatistics statsObj)
Write table level column statistics to persistent store
|
void |
validatePartitionNameCharacters(List<String> partVals) |
WMValidateResourcePlanResponse |
validateResourcePlan(String resourcePlanName) |
boolean isCompatibleWith(org.apache.hadoop.conf.Configuration conf)
void setHiveAddedJars(String addedJars)
addedJars
- the hive.added.jars.path. It is qualified paths separated by commas.boolean isLocalMetaStore()
void reconnect() throws MetaException
MetaException
void close()
void setMetaConf(String key, String value) throws MetaException, org.apache.thrift.TException
MetaException
org.apache.thrift.TException
String getMetaConf(String key) throws MetaException, org.apache.thrift.TException
MetaException
org.apache.thrift.TException
void createCatalog(Catalog catalog) throws AlreadyExistsException, InvalidObjectException, MetaException, org.apache.thrift.TException
catalog
- catalog object to create.AlreadyExistsException
- A catalog of this name already exists.InvalidObjectException
- There is something wrong with the passed in catalog object.MetaException
- something went wrong, usually either in the database or trying to
create the directory for the catalog.org.apache.thrift.TException
- general thrift exception.void alterCatalog(String catalogName, Catalog newCatalog) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
catalogName
- the name of the catalog to alter.newCatalog
- the new catalog object. All relevant details of the catalog should be
set, don't rely on the system to figure out what you changed and only copy
that in.NoSuchObjectException
- no catalog of this name existsInvalidObjectException
- an attempt was made to make an unsupported change (such as
catalog name).MetaException
- usually indicates a database errororg.apache.thrift.TException
- general thrift exceptionCatalog getCatalog(String catName) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catName
- Name of the catalog to fetch.NoSuchObjectException
- no catalog of this name exists.MetaException
- something went wrong, usually in the database.org.apache.thrift.TException
- general thrift exception.List<String> getCatalogs() throws MetaException, org.apache.thrift.TException
MetaException
- something went wrong, usually in the database.org.apache.thrift.TException
- general thrift exception.void dropCatalog(String catName) throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException
catName
- name of the catalog to dropNoSuchObjectException
- no catalog of this name exists.InvalidOperationException
- The catalog is not empty and cannot be dropped.MetaException
- something went wrong, usually in the database.org.apache.thrift.TException
- general thrift exception.List<String> getDatabases(String databasePattern) throws MetaException, org.apache.thrift.TException
databasePattern
- pattern for the database name to patchMetaException
- error accessing RDBMS.org.apache.thrift.TException
- thrift transport errorList<String> getDatabases(String catName, String databasePattern) throws MetaException, org.apache.thrift.TException
catName
- catalog name. Can be null, in which case the default catalog is assumed.databasePattern
- pattern for the database name to matchMetaException
- error accessing RDBMS.org.apache.thrift.TException
- thrift transport errorList<String> getAllDatabases() throws MetaException, org.apache.thrift.TException
MetaException
- error accessing RDBMS.org.apache.thrift.TException
- thrift transport errorList<String> getAllDatabases(String catName) throws MetaException, org.apache.thrift.TException
catName
- catalog name. Can be null, in which case the default catalog is assumed.MetaException
- error accessing RDBMS.org.apache.thrift.TException
- thrift transport errorList<String> getTables(String dbName, String tablePattern) throws MetaException, org.apache.thrift.TException, UnknownDBException
dbName
- database name.tablePattern
- pattern for table name to conform toMetaException
- error fetching information from the RDBMSorg.apache.thrift.TException
- thrift transport errorUnknownDBException
- indicated database to search in does not exist.List<String> getTables(String catName, String dbName, String tablePattern) throws MetaException, org.apache.thrift.TException, UnknownDBException
catName
- catalog name.dbName
- database name.tablePattern
- pattern for table name to conform toMetaException
- error fetching information from the RDBMSorg.apache.thrift.TException
- general thrift errorUnknownDBException
- indicated database to search in does not exist.List<String> getTables(String dbName, String tablePattern, TableType tableType) throws MetaException, org.apache.thrift.TException, UnknownDBException
dbName
- Name of the database to fetch tables in.tablePattern
- pattern to match for table names.tableType
- Type of the table in the HMS store. VIRTUAL_VIEW is for views.MetaException
- error fetching information from the RDBMSorg.apache.thrift.TException
- thrift transport errorUnknownDBException
- indicated database does not exist.List<String> getTables(String catName, String dbName, String tablePattern, TableType tableType) throws MetaException, org.apache.thrift.TException, UnknownDBException
catName
- catalog name.dbName
- Name of the database to fetch tables in.tablePattern
- pattern to match for table names.tableType
- Type of the table in the HMS store. VIRTUAL_VIEW is for views.MetaException
- error fetching information from the RDBMSorg.apache.thrift.TException
- thrift transport errorUnknownDBException
- indicated database does not exist.List<String> getMaterializedViewsForRewriting(String dbName) throws MetaException, org.apache.thrift.TException, UnknownDBException
dbName
- Name of the database to fetch materialized views from.MetaException
- error fetching from the RDBMSorg.apache.thrift.TException
- thrift transport errorUnknownDBException
- no such databaseList<String> getMaterializedViewsForRewriting(String catName, String dbName) throws MetaException, org.apache.thrift.TException, UnknownDBException
catName
- catalog name.dbName
- Name of the database to fetch materialized views from.MetaException
- error fetching from the RDBMSorg.apache.thrift.TException
- thrift transport errorUnknownDBException
- no such databaseList<TableMeta> getTableMeta(String dbPatterns, String tablePatterns, List<String> tableTypes) throws MetaException, org.apache.thrift.TException, UnknownDBException
dbPatterns
- database pattern to match, or null for all databasestablePatterns
- table pattern to match.tableTypes
- list of table types to fetch.MetaException
- something went wrong with the fetch from the RDBMSorg.apache.thrift.TException
- thrift transport errorUnknownDBException
- No databases match the provided pattern.List<TableMeta> getTableMeta(String catName, String dbPatterns, String tablePatterns, List<String> tableTypes) throws MetaException, org.apache.thrift.TException, UnknownDBException
catName
- catalog to search in. Search cannot cross catalogs.dbPatterns
- database pattern to match, or null for all databasestablePatterns
- table pattern to match.tableTypes
- list of table types to fetch.MetaException
- something went wrong with the fetch from the RDBMSorg.apache.thrift.TException
- thrift transport errorUnknownDBException
- No databases match the provided pattern.List<String> getAllTables(String dbName) throws MetaException, org.apache.thrift.TException, UnknownDBException
dbName
- database nameMetaException
- something went wrong with the fetch from the RDBMSorg.apache.thrift.TException
- thrift transport errorUnknownDBException
- No databases match the provided pattern.List<String> getAllTables(String catName, String dbName) throws MetaException, org.apache.thrift.TException, UnknownDBException
catName
- catalog namedbName
- database nameMetaException
- something went wrong with the fetch from the RDBMSorg.apache.thrift.TException
- thrift transport errorUnknownDBException
- No databases match the provided pattern.List<String> listTableNamesByFilter(String dbName, String filter, short maxTables) throws org.apache.thrift.TException, InvalidOperationException, UnknownDBException
dbName
- The name of the database from which you will retrieve the table namesfilter
- The filter stringmaxTables
- The maximum number of tables returnedInvalidOperationException
- invalid filterUnknownDBException
- no such databaseorg.apache.thrift.TException
- thrift transport errorList<String> listTableNamesByFilter(String catName, String dbName, String filter, int maxTables) throws org.apache.thrift.TException, InvalidOperationException, UnknownDBException
catName
- catalog namedbName
- The name of the database from which you will retrieve the table namesfilter
- The filter stringmaxTables
- The maximum number of tables returnedInvalidOperationException
- invalid filterUnknownDBException
- no such databaseorg.apache.thrift.TException
- thrift transport errorvoid dropTable(String dbname, String tableName, boolean deleteData, boolean ignoreUnknownTab) throws MetaException, org.apache.thrift.TException, NoSuchObjectException
dbname
- The database for this tabletableName
- The table to dropdeleteData
- Should we delete the underlying dataignoreUnknownTab
- don't throw if the requested table doesn't existMetaException
- Could not drop table properly.NoSuchObjectException
- The table wasn't found.org.apache.thrift.TException
- A thrift communication error occurredvoid dropTable(String dbname, String tableName, boolean deleteData, boolean ignoreUnknownTab, boolean ifPurge) throws MetaException, org.apache.thrift.TException, NoSuchObjectException
dbname
- The database for this tabletableName
- The table to dropdeleteData
- Should we delete the underlying dataignoreUnknownTab
- don't throw if the requested table doesn't existifPurge
- completely purge the table (skipping trash) while removing data from warehouseMetaException
- Could not drop table properly.NoSuchObjectException
- The table wasn't found.org.apache.thrift.TException
- A thrift communication error occurredvoid dropTable(String dbname, String tableName) throws MetaException, org.apache.thrift.TException, NoSuchObjectException
dbname
- The database for this tabletableName
- The table to dropMetaException
- Could not drop table properly.NoSuchObjectException
- The table wasn't found.org.apache.thrift.TException
- A thrift communication error occurredvoid dropTable(String catName, String dbName, String tableName, boolean deleteData, boolean ignoreUnknownTable, boolean ifPurge) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
catName
- catalog the table is in.dbName
- database the table is in.tableName
- table name.deleteData
- whether associated data should be deleted.ignoreUnknownTable
- whether a non-existent table name should be ignoredifPurge
- whether dropped data should be immediately removed rather than placed in HDFS
trash.MetaException
- something went wrong, usually in the RDBMS or storage.NoSuchObjectException
- No table of this name exists, only thrown if
ignoreUnknownTable is false.org.apache.thrift.TException
- general thrift error.default void dropTable(String catName, String dbName, String tableName, boolean deleteData, boolean ignoreUnknownTable) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
dropTable(String, String, String, boolean, boolean, boolean)
with ifPurge set to
false.catName
- catalog the table is in.dbName
- database the table is in.tableName
- table name.deleteData
- whether associated data should be deleted.ignoreUnknownTable
- whether a non-existent table name should be ignoredMetaException
- something went wrong, usually in the RDBMS or storage.NoSuchObjectException
- No table of this name exists, only thrown if
ignoreUnknownTable is false.org.apache.thrift.TException
- general thrift error.default void dropTable(String catName, String dbName, String tableName) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
dropTable(String, String, String, boolean, boolean, boolean)
with deleteData
set and ignoreUnknownTable set to true and ifPurge set to false.catName
- catalog the table is in.dbName
- database the table is in.tableName
- table name.MetaException
- something went wrong, usually in the RDBMS or storage.NoSuchObjectException
- No table of this name exists, only thrown if
ignoreUnknownTable is false.org.apache.thrift.TException
- general thrift error.void truncateTable(String dbName, String tableName, List<String> partNames) throws MetaException, org.apache.thrift.TException
dbName
- The db to which the table to be truncate belongs totableName
- The table to truncatepartNames
- List of partitions to truncate. NULL will truncate the whole table/all partitionsMetaException
- Failure in the RDBMS or storageorg.apache.thrift.TException
- Thrift transport exceptionvoid truncateTable(String catName, String dbName, String tableName, List<String> partNames) throws MetaException, org.apache.thrift.TException
catName
- catalog namedbName
- The db to which the table to be truncate belongs totableName
- The table to truncatepartNames
- List of partitions to truncate. NULL will truncate the whole table/all partitionsMetaException
- Failure in the RDBMS or storageorg.apache.thrift.TException
- Thrift transport exceptionCmRecycleResponse recycleDirToCmPath(CmRecycleRequest request) throws MetaException, org.apache.thrift.TException
request
- Inputs for path of the data files to be recycled to cmroot and
isPurge flag when set to true files which needs to be recycled are not moved to TrashMetaException
org.apache.thrift.TException
boolean tableExists(String databaseName, String tableName) throws MetaException, org.apache.thrift.TException, UnknownDBException
databaseName
- database nametableName
- table nameMetaException
- error fetching form the RDBMSorg.apache.thrift.TException
- thrift transport errorUnknownDBException
- the indicated database does not exist.boolean tableExists(String catName, String dbName, String tableName) throws MetaException, org.apache.thrift.TException, UnknownDBException
catName
- catalog namedbName
- database nametableName
- table nameMetaException
- error fetching form the RDBMSorg.apache.thrift.TException
- thrift transport errorUnknownDBException
- the indicated database does not exist.Database getDatabase(String databaseName) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
databaseName
- name of the database to fetchNoSuchObjectException
- The database does not existMetaException
- Could not fetch the databaseorg.apache.thrift.TException
- A thrift communication error occurredDatabase getDatabase(String catalogName, String databaseName) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catalogName
- catalog name. Can be null, in which case
Warehouse.DEFAULT_CATALOG_NAME
will be assumed.databaseName
- database nameNoSuchObjectException
- No database with this name exists in the specified catalogMetaException
- something went wrong, usually in the RDBMSorg.apache.thrift.TException
- general thrift errorTable getTable(String dbName, String tableName) throws MetaException, org.apache.thrift.TException, NoSuchObjectException
dbName
- The database the table is located in.tableName
- Name of the table to fetch.MetaException
- Could not fetch the tableorg.apache.thrift.TException
- A thrift communication error occurredNoSuchObjectException
- In case the table wasn't found.Table getTable(String catName, String dbName, String tableName) throws MetaException, org.apache.thrift.TException
catName
- catalog the table is in.dbName
- database the table is in.tableName
- table name.MetaException
- Something went wrong, usually in the RDBMS.org.apache.thrift.TException
- general thrift error.List<Table> getTableObjectsByName(String dbName, List<String> tableNames) throws MetaException, InvalidOperationException, UnknownDBException, org.apache.thrift.TException
dbName
- The database the tables are located in.tableNames
- The names of the tables to fetchInvalidOperationException
- The input to this operation is invalid (e.g., the list of tables names is null)UnknownDBException
- The requested database could not be fetched.org.apache.thrift.TException
- A thrift communication error occurredMetaException
- Any other errorsList<Table> getTableObjectsByName(String catName, String dbName, List<String> tableNames) throws MetaException, InvalidOperationException, UnknownDBException, org.apache.thrift.TException
catName
- catalog namedbName
- The database the tables are located in.tableNames
- The names of the tables to fetchInvalidOperationException
- The input to this operation is invalid (e.g., the list of tables names is null)UnknownDBException
- The requested database could not be fetched.org.apache.thrift.TException
- A thrift communication error occurredMetaException
- Any other errorsMaterialization getMaterializationInvalidationInfo(CreationMetadata cm, String validTxnList) throws MetaException, InvalidOperationException, UnknownDBException, org.apache.thrift.TException
MetaException
InvalidOperationException
UnknownDBException
org.apache.thrift.TException
void updateCreationMetadata(String dbName, String tableName, CreationMetadata cm) throws MetaException, org.apache.thrift.TException
MetaException
org.apache.thrift.TException
void updateCreationMetadata(String catName, String dbName, String tableName, CreationMetadata cm) throws MetaException, org.apache.thrift.TException
MetaException
org.apache.thrift.TException
Partition appendPartition(String dbName, String tableName, List<String> partVals) throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException
dbName
- database nametableName
- table namepartVals
- partition valuesInvalidObjectException
- no such tableAlreadyExistsException
- a partition with these values already existsMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorPartition appendPartition(String catName, String dbName, String tableName, List<String> partVals) throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException
catName
- catalog namedbName
- database nametableName
- table namepartVals
- partition valuesInvalidObjectException
- no such tableAlreadyExistsException
- a partition with these values already existsMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorPartition appendPartition(String dbName, String tableName, String name) throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException
dbName
- database name.tableName
- table name.name
- name of the partition, should be in the form partkey=partval.InvalidObjectException
- No such table.AlreadyExistsException
- Partition of this name already exists.MetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorPartition appendPartition(String catName, String dbName, String tableName, String name) throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException
catName
- catalog name.dbName
- database name.tableName
- table name.name
- name of the partition, should be in the form partkey=partval.InvalidObjectException
- No such table.AlreadyExistsException
- Partition of this name already exists.MetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorPartition add_partition(Partition partition) throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException
partition
- The partition to addInvalidObjectException
- Could not find table to add toAlreadyExistsException
- Partition already existsMetaException
- Could not add partitionorg.apache.thrift.TException
- Thrift exceptionint add_partitions(List<Partition> partitions) throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException
partitions
- The partitions to addInvalidObjectException
- Could not find table to add toAlreadyExistsException
- Partition already existsMetaException
- Could not add partitionorg.apache.thrift.TException
- Thrift exceptionint add_partitions_pspec(PartitionSpecProxy partitionSpec) throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException
partitionSpec
- partition spec proxyInvalidObjectException
- the partitionSpec is malformed.AlreadyExistsException
- one or more of the partitions already exist.MetaException
- error accessing the RDBMS or storage.org.apache.thrift.TException
- thrift transport errorList<Partition> add_partitions(List<Partition> partitions, boolean ifNotExists, boolean needResults) throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException
partitions
- The partitions to addifNotExists
- only add partitions if they don't existneedResults
- Whether the results are neededInvalidObjectException
AlreadyExistsException
MetaException
org.apache.thrift.TException
Partition getPartition(String dbName, String tblName, List<String> partVals) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
dbName
- database nametblName
- table namepartVals
- partition values for this partition, must be in the same order as the
partition keys of the table.NoSuchObjectException
- no such partitionMetaException
- error access the RDBMS.org.apache.thrift.TException
- thrift transport errorPartition getPartition(String catName, String dbName, String tblName, List<String> partVals) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catName
- catalog namedbName
- database nametblName
- table namepartVals
- partition values for this partition, must be in the same order as the
partition keys of the table.NoSuchObjectException
- no such partitionMetaException
- error access the RDBMS.org.apache.thrift.TException
- thrift transport errorPartition exchange_partition(Map<String,String> partitionSpecs, String sourceDb, String sourceTable, String destdb, String destTableName) throws MetaException, NoSuchObjectException, InvalidObjectException, org.apache.thrift.TException
partitionSpecs
- key value pairs that describe the partition to be moved.sourceDb
- database of the source tablesourceTable
- name of the source tabledestdb
- database of the destination tabledestTableName
- name of the destination tableMetaException
- error accessing the RDBMS or storageNoSuchObjectException
- no such table, for either source or destination tableInvalidObjectException
- error in partition specificationsorg.apache.thrift.TException
- thrift transport errorPartition exchange_partition(Map<String,String> partitionSpecs, String sourceCat, String sourceDb, String sourceTable, String destCat, String destdb, String destTableName) throws MetaException, NoSuchObjectException, InvalidObjectException, org.apache.thrift.TException
partitionSpecs
- key value pairs that describe the partition to be moved.sourceCat
- catalog of the source tablesourceDb
- database of the source tablesourceTable
- name of the source tabledestCat
- catalog of the destination table, for now must the same as sourceCatdestdb
- database of the destination tabledestTableName
- name of the destination tableMetaException
- error accessing the RDBMS or storageNoSuchObjectException
- no such table, for either source or destination tableInvalidObjectException
- error in partition specificationsorg.apache.thrift.TException
- thrift transport errorList<Partition> exchange_partitions(Map<String,String> partitionSpecs, String sourceDb, String sourceTable, String destdb, String destTableName) throws MetaException, NoSuchObjectException, InvalidObjectException, org.apache.thrift.TException
partitionSpecs
- key value pairs that describe the partition(s) to be moved.sourceDb
- database of the source tablesourceTable
- name of the source tabledestdb
- database of the destination tabledestTableName
- name of the destination tableMetaException
- error accessing the RDBMS or storageNoSuchObjectException
- no such table, for either source or destination tableInvalidObjectException
- error in partition specificationsorg.apache.thrift.TException
- thrift transport errorList<Partition> exchange_partitions(Map<String,String> partitionSpecs, String sourceCat, String sourceDb, String sourceTable, String destCat, String destdb, String destTableName) throws MetaException, NoSuchObjectException, InvalidObjectException, org.apache.thrift.TException
partitionSpecs
- key value pairs that describe the partition(s) to be moved.sourceCat
- catalog of the source tablesourceDb
- database of the source tablesourceTable
- name of the source tabledestCat
- catalog of the destination table, for now must the same as sourceCatdestdb
- database of the destination tabledestTableName
- name of the destination tableMetaException
- error accessing the RDBMS or storageNoSuchObjectException
- no such table, for either source or destination tableInvalidObjectException
- error in partition specificationsorg.apache.thrift.TException
- thrift transport errorPartition getPartition(String dbName, String tblName, String name) throws MetaException, UnknownTableException, NoSuchObjectException, org.apache.thrift.TException
dbName
- database name.tblName
- table name.name
- - partition name i.e. 'ds=2010-02-03/ts=2010-02-03 18%3A16%3A01'MetaException
- error access the RDBMS.org.apache.thrift.TException
- thrift transport errorUnknownTableException
NoSuchObjectException
Partition getPartition(String catName, String dbName, String tblName, String name) throws MetaException, UnknownTableException, NoSuchObjectException, org.apache.thrift.TException
catName
- catalog name.dbName
- database name.tblName
- table name.name
- - partition name i.e. 'ds=2010-02-03/ts=2010-02-03 18%3A16%3A01'MetaException
- error access the RDBMS.org.apache.thrift.TException
- thrift transport errorUnknownTableException
NoSuchObjectException
Partition getPartitionWithAuthInfo(String dbName, String tableName, List<String> pvals, String userName, List<String> groupNames) throws MetaException, UnknownTableException, NoSuchObjectException, org.apache.thrift.TException
dbName
- database nametableName
- table namepvals
- partition values, must be in the same order as the tables partition keysuserName
- name of the calling usergroupNames
- groups the callMetaException
- error accessing the RDBMSUnknownTableException
- no such tableNoSuchObjectException
- no such partitionorg.apache.thrift.TException
- thrift transport errorPartition getPartitionWithAuthInfo(String catName, String dbName, String tableName, List<String> pvals, String userName, List<String> groupNames) throws MetaException, UnknownTableException, NoSuchObjectException, org.apache.thrift.TException
catName
- catalog namedbName
- database nametableName
- table namepvals
- partition values, must be in the same order as the tables partition keysuserName
- name of the calling usergroupNames
- groups the callMetaException
- error accessing the RDBMSUnknownTableException
- no such tableNoSuchObjectException
- no such partitionorg.apache.thrift.TException
- thrift transport errorList<Partition> listPartitions(String db_name, String tbl_name, short max_parts) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
db_name
- database nametbl_name
- table namemax_parts
- maximum number of parts to return, -1 for allNoSuchObjectException
- No such table.MetaException
- error accessing RDBMS.org.apache.thrift.TException
- thrift transport errorList<Partition> listPartitions(String catName, String db_name, String tbl_name, int max_parts) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catName
- catalog namedb_name
- database nametbl_name
- table namemax_parts
- maximum number of parts to return, -1 for allNoSuchObjectException
- No such table.MetaException
- error accessing RDBMS.org.apache.thrift.TException
- thrift transport errorPartitionSpecProxy listPartitionSpecs(String dbName, String tableName, int maxParts) throws org.apache.thrift.TException
dbName
- database name.tableName
- table name.maxParts
- maximum number of partitions to return, or -1 for allorg.apache.thrift.TException
- thrift transport errorPartitionSpecProxy listPartitionSpecs(String catName, String dbName, String tableName, int maxParts) throws org.apache.thrift.TException
catName
- catalog name.dbName
- database name.tableName
- table name.maxParts
- maximum number of partitions to return, or -1 for allorg.apache.thrift.TException
- thrift transport errorList<Partition> listPartitions(String db_name, String tbl_name, List<String> part_vals, short max_parts) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
db_name
- database name.tbl_name
- table name.part_vals
- partition values, in order of the table partition keys. These can be
partial, or .* to match all values for a particular key.max_parts
- maximum number of partitions to return, or -1 for all.NoSuchObjectException
- no such table.MetaException
- error accessing the database or processing the partition values.org.apache.thrift.TException
- thrift transport error.List<Partition> listPartitions(String catName, String db_name, String tbl_name, List<String> part_vals, int max_parts) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catName
- catalog name.db_name
- database name.tbl_name
- table name.part_vals
- partition values, in order of the table partition keys. These can be
partial, or .* to match all values for a particular key.max_parts
- maximum number of partitions to return, or -1 for all.NoSuchObjectException
- no such table.MetaException
- error accessing the database or processing the partition values.org.apache.thrift.TException
- thrift transport error.List<String> listPartitionNames(String db_name, String tbl_name, short max_parts) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
db_name
- database name.tbl_name
- table name.max_parts
- maximum number of parts of fetch, or -1 to fetch them all.NoSuchObjectException
- No such table.MetaException
- Error accessing the RDBMS.org.apache.thrift.TException
- thrift transport errorList<String> listPartitionNames(String catName, String db_name, String tbl_name, int max_parts) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catName
- catalog name.db_name
- database name.tbl_name
- table name.max_parts
- maximum number of parts of fetch, or -1 to fetch them all.NoSuchObjectException
- No such table.MetaException
- Error accessing the RDBMS.org.apache.thrift.TException
- thrift transport errorList<String> listPartitionNames(String db_name, String tbl_name, List<String> part_vals, short max_parts) throws MetaException, org.apache.thrift.TException, NoSuchObjectException
db_name
- database name.tbl_name
- table name.part_vals
- partial list of partition values. These must be given in the order of the
partition keys. If you wish to accept any value for a particular key you
can pass ".*" for that value in this list.max_parts
- maximum number of partition names to return, or -1 to return all that are
found.MetaException
- error accessing the RDBMS.org.apache.thrift.TException
- thrift transport error.NoSuchObjectException
- no such table.List<String> listPartitionNames(String catName, String db_name, String tbl_name, List<String> part_vals, int max_parts) throws MetaException, org.apache.thrift.TException, NoSuchObjectException
catName
- catalog name.db_name
- database name.tbl_name
- table name.part_vals
- partial list of partition values. These must be given in the order of the
partition keys. If you wish to accept any value for a particular key you
can pass ".*" for that value in this list.max_parts
- maximum number of partition names to return, or -1 to return all that are
found.MetaException
- error accessing the RDBMS.org.apache.thrift.TException
- thrift transport error.NoSuchObjectException
- no such table.PartitionValuesResponse listPartitionValues(PartitionValuesRequest request) throws MetaException, org.apache.thrift.TException, NoSuchObjectException
request
- requestMetaException
- error accessing RDBMSorg.apache.thrift.TException
- thrift transport errorNoSuchObjectException
- no such tableint getNumPartitionsByFilter(String dbName, String tableName, String filter) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
dbName
- the database nametableName
- the table namefilter
- the filter string,
for example "part1 = \"p1_abc\" and part2 <= "\p2_test\"". Filtering can
be done only on string partition keys.MetaException
- error accessing RDBMS or processing the filterNoSuchObjectException
- no such tableorg.apache.thrift.TException
- thrift transport errorint getNumPartitionsByFilter(String catName, String dbName, String tableName, String filter) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
catName
- catalog namedbName
- the database nametableName
- the table namefilter
- the filter string,
for example "part1 = \"p1_abc\" and part2 <= "\p2_test\"". Filtering can
be done only on string partition keys.MetaException
- error accessing RDBMS or processing the filterNoSuchObjectException
- no such tableorg.apache.thrift.TException
- thrift transport errorList<Partition> listPartitionsByFilter(String db_name, String tbl_name, String filter, short max_parts) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
db_name
- the database nametbl_name
- the table namefilter
- the filter string,
for example "part1 = \"p1_abc\" and part2 <= "\p2_test\"". Filtering can
be done only on string partition keys.max_parts
- the maximum number of partitions to return,
all partitions are returned if -1 is passedMetaException
- Error accessing the RDBMS or processing the filter.NoSuchObjectException
- No such table.org.apache.thrift.TException
- thrift transport errorList<Partition> listPartitionsByFilter(String catName, String db_name, String tbl_name, String filter, int max_parts) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
catName
- catalog name.db_name
- the database nametbl_name
- the table namefilter
- the filter string,
for example "part1 = \"p1_abc\" and part2 <= "\p2_test\"". Filtering can
be done only on string partition keys.max_parts
- the maximum number of partitions to return,
all partitions are returned if -1 is passedMetaException
- Error accessing the RDBMS or processing the filter.NoSuchObjectException
- No such table.org.apache.thrift.TException
- thrift transport errorPartitionSpecProxy listPartitionSpecsByFilter(String db_name, String tbl_name, String filter, int max_parts) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
db_name
- database nametbl_name
- table namefilter
- SQL where clause filtermax_parts
- maximum number of partitions to fetch, or -1 for allMetaException
- error accessing RDBMS or processing the filterNoSuchObjectException
- No table matches the requestorg.apache.thrift.TException
- thrift transport errorPartitionSpecProxy listPartitionSpecsByFilter(String catName, String db_name, String tbl_name, String filter, int max_parts) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
catName
- catalog namedb_name
- database nametbl_name
- table namefilter
- SQL where clause filtermax_parts
- maximum number of partitions to fetch, or -1 for allMetaException
- error accessing RDBMS or processing the filterNoSuchObjectException
- No table matches the requestorg.apache.thrift.TException
- thrift transport errorboolean listPartitionsByExpr(String db_name, String tbl_name, byte[] expr, String default_partition_name, short max_parts, List<Partition> result) throws org.apache.thrift.TException
db_name
- the database nametbl_name
- the table nameexpr
- expression, serialized from ExprNodeDescmax_parts
- the maximum number of partitions to return,
all partitions are returned if -1 is passeddefault_partition_name
- Default partition name from configuration. If blank, the
metastore server-side configuration is used.result
- the resulting list of partitionsorg.apache.thrift.TException
- thrift transport error or error executing the filter.boolean listPartitionsByExpr(String catName, String db_name, String tbl_name, byte[] expr, String default_partition_name, int max_parts, List<Partition> result) throws org.apache.thrift.TException
catName
- catalog namedb_name
- the database nametbl_name
- the table nameexpr
- expression, serialized from ExprNodeDescmax_parts
- the maximum number of partitions to return,
all partitions are returned if -1 is passeddefault_partition_name
- Default partition name from configuration. If blank, the
metastore server-side configuration is used.result
- the resulting list of partitionsorg.apache.thrift.TException
- thrift transport error or error executing the filter.List<Partition> listPartitionsWithAuthInfo(String dbName, String tableName, short maxParts, String userName, List<String> groupNames) throws MetaException, org.apache.thrift.TException, NoSuchObjectException
dbName
- database nametableName
- table namemaxParts
- maximum number of partitions to fetch, or -1 for alluserName
- user to fetch privileges forgroupNames
- groups to fetch privileges forNoSuchObjectException
- no partitions matching the criteria were foundMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorList<Partition> listPartitionsWithAuthInfo(String catName, String dbName, String tableName, int maxParts, String userName, List<String> groupNames) throws MetaException, org.apache.thrift.TException, NoSuchObjectException
catName
- catalog namedbName
- database nametableName
- table namemaxParts
- maximum number of partitions to fetch, or -1 for alluserName
- user to fetch privileges forgroupNames
- groups to fetch privileges forNoSuchObjectException
- no partitions matching the criteria were foundMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorList<Partition> getPartitionsByNames(String db_name, String tbl_name, List<String> part_names) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
db_name
- database nametbl_name
- table namepart_names
- list of partition namesNoSuchObjectException
- No such partitionsMetaException
- error accessing the RDBMS.org.apache.thrift.TException
- thrift transport errorList<Partition> getPartitionsByNames(String catName, String db_name, String tbl_name, List<String> part_names) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catName
- catalog namedb_name
- database nametbl_name
- table namepart_names
- list of partition namesNoSuchObjectException
- No such partitionsMetaException
- error accessing the RDBMS.org.apache.thrift.TException
- thrift transport errorList<Partition> listPartitionsWithAuthInfo(String dbName, String tableName, List<String> partialPvals, short maxParts, String userName, List<String> groupNames) throws MetaException, org.apache.thrift.TException, NoSuchObjectException
dbName
- database nametableName
- table namepartialPvals
- partition values, can be partialmaxParts
- maximum number of partitions to fetch, or -1 for alluserName
- user to fetch privilege information forgroupNames
- group to fetch privilege information forNoSuchObjectException
- no partitions matching the criteria were foundMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorList<Partition> listPartitionsWithAuthInfo(String catName, String dbName, String tableName, List<String> partialPvals, int maxParts, String userName, List<String> groupNames) throws MetaException, org.apache.thrift.TException, NoSuchObjectException
dbName
- database nametableName
- table namepartialPvals
- partition values, can be partialmaxParts
- maximum number of partitions to fetch, or -1 for alluserName
- user to fetch privilege information forgroupNames
- group to fetch privilege information forNoSuchObjectException
- no partitions matching the criteria were foundMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorvoid markPartitionForEvent(String db_name, String tbl_name, Map<String,String> partKVs, PartitionEventType eventType) throws MetaException, NoSuchObjectException, org.apache.thrift.TException, UnknownTableException, UnknownDBException, UnknownPartitionException, InvalidPartitionException
db_name
- database nametbl_name
- table namepartKVs
- key value pairs that describe the partitioneventType
- type of the eventMetaException
- error access the RDBMSNoSuchObjectException
- never throws this AFAICTorg.apache.thrift.TException
- thrift transport errorUnknownTableException
- no such tableUnknownDBException
- no such databaseUnknownPartitionException
- no such partitionInvalidPartitionException
- partition partKVs is invalidvoid markPartitionForEvent(String catName, String db_name, String tbl_name, Map<String,String> partKVs, PartitionEventType eventType) throws MetaException, NoSuchObjectException, org.apache.thrift.TException, UnknownTableException, UnknownDBException, UnknownPartitionException, InvalidPartitionException
catName
- catalog namedb_name
- database nametbl_name
- table namepartKVs
- key value pairs that describe the partitioneventType
- type of the eventMetaException
- error access the RDBMSNoSuchObjectException
- never throws this AFAICTorg.apache.thrift.TException
- thrift transport errorUnknownTableException
- no such tableUnknownDBException
- no such databaseUnknownPartitionException
- no such partitionInvalidPartitionException
- partition partKVs is invalidboolean isPartitionMarkedForEvent(String db_name, String tbl_name, Map<String,String> partKVs, PartitionEventType eventType) throws MetaException, NoSuchObjectException, org.apache.thrift.TException, UnknownTableException, UnknownDBException, UnknownPartitionException, InvalidPartitionException
db_name
- database nametbl_name
- table name.partKVs
- key value pairs that describe the partition.eventType
- event typeMetaException
- error access the RDBMSNoSuchObjectException
- never throws this AFAICTorg.apache.thrift.TException
- thrift transport errorUnknownTableException
- no such tableUnknownDBException
- no such databaseUnknownPartitionException
- no such partitionInvalidPartitionException
- partition partKVs is invalidboolean isPartitionMarkedForEvent(String catName, String db_name, String tbl_name, Map<String,String> partKVs, PartitionEventType eventType) throws MetaException, NoSuchObjectException, org.apache.thrift.TException, UnknownTableException, UnknownDBException, UnknownPartitionException, InvalidPartitionException
catName
- catalog namedb_name
- database nametbl_name
- table name.partKVs
- key value pairs that describe the partition.eventType
- event typeMetaException
- error access the RDBMSNoSuchObjectException
- never throws this AFAICTorg.apache.thrift.TException
- thrift transport errorUnknownTableException
- no such tableUnknownDBException
- no such databaseUnknownPartitionException
- no such partitionInvalidPartitionException
- partition partKVs is invalidvoid validatePartitionNameCharacters(List<String> partVals) throws org.apache.thrift.TException, MetaException
partVals
- org.apache.thrift.TException
MetaException
void createTable(Table tbl) throws AlreadyExistsException, InvalidObjectException, MetaException, NoSuchObjectException, org.apache.thrift.TException
tbl
- AlreadyExistsException
InvalidObjectException
MetaException
NoSuchObjectException
org.apache.thrift.TException
ThriftHiveMetastore.Iface.create_table(org.apache.hadoop.hive.metastore.api.Table)
void alter_table(String databaseName, String tblName, Table table) throws InvalidOperationException, MetaException, org.apache.thrift.TException
databaseName
- database nametblName
- table nametable
- new table object, should be complete representation of the table, not just the
things you want to change.InvalidOperationException
- something is wrong with the new table object or an
operation was attempted that is not allowed (such as changing partition columns).MetaException
- something went wrong, usually in the RDBMSorg.apache.thrift.TException
- general thrift exceptiondefault void alter_table(String catName, String dbName, String tblName, Table newTable) throws InvalidOperationException, MetaException, org.apache.thrift.TException
alter_table(String, String, String, Table, EnvironmentContext)
with
EnvironmentContext set to null.catName
- catalog name.dbName
- database name.tblName
- table name.newTable
- new table object, should be complete representation of the table, not just the
things you want to change.InvalidOperationException
- something is wrong with the new table object or an
operation was attempted that is not allowed (such as changing partition columns).MetaException
- something went wrong, usually in the RDBMSorg.apache.thrift.TException
- general thrift exceptionvoid alter_table(String catName, String dbName, String tblName, Table newTable, EnvironmentContext envContext) throws InvalidOperationException, MetaException, org.apache.thrift.TException
catName
- catalog name.dbName
- database name.tblName
- table name.newTable
- new table object, should be complete representation of the table, not just the
things you want to change.envContext
- options for the alter.InvalidOperationException
- something is wrong with the new table object or an
operation was attempted that is not allowed (such as changing partition columns).MetaException
- something went wrong, usually in the RDBMSorg.apache.thrift.TException
- general thrift exception@Deprecated void alter_table(String defaultDatabaseName, String tblName, Table table, boolean cascade) throws InvalidOperationException, MetaException, org.apache.thrift.TException
StatsSetupConst.CASCADE
InvalidOperationException
MetaException
org.apache.thrift.TException
void alter_table_with_environmentContext(String databaseName, String tblName, Table table, EnvironmentContext environmentContext) throws InvalidOperationException, MetaException, org.apache.thrift.TException
databaseName
- database nametblName
- table nametable
- new table object, should be complete representation of the table, not just the
things you want to change.environmentContext
- options for the alter.InvalidOperationException
- something is wrong with the new table object or an
operation was attempted that is not allowed (such as changing partition columns).MetaException
- something went wrong, usually in the RDBMSorg.apache.thrift.TException
- general thrift exceptionvoid createDatabase(Database db) throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException
db
- database object. If the catalog name is null it will be assumed to be
Warehouse.DEFAULT_CATALOG_NAME
.InvalidObjectException
- There is something wrong with the database object.AlreadyExistsException
- There is already a database of this name in the specified
catalog.MetaException
- something went wrong, usually in the RDBMSorg.apache.thrift.TException
- general thrift errorvoid dropDatabase(String name) throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException
name
- name of the database to drop.NoSuchObjectException
- No such database exists.InvalidOperationException
- The database cannot be dropped because it is not empty.MetaException
- something went wrong, usually either in the RDMBS or in storage.org.apache.thrift.TException
- general thrift error.void dropDatabase(String name, boolean deleteData, boolean ignoreUnknownDb) throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException
name
- name of the database to drop.deleteData
- whether to drop the underlying HDFS directory.ignoreUnknownDb
- whether to ignore an attempt to drop a non-existant databaseNoSuchObjectException
- No database of this name exists in the specified catalog and
ignoreUnknownDb is false.InvalidOperationException
- The database cannot be dropped because it is not empty.MetaException
- something went wrong, usually either in the RDMBS or in storage.org.apache.thrift.TException
- general thrift error.void dropDatabase(String name, boolean deleteData, boolean ignoreUnknownDb, boolean cascade) throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException
name
- database name.deleteData
- whether to drop the underlying HDFS directory.ignoreUnknownDb
- whether to ignore an attempt to drop a non-existant databasecascade
- whether to drop contained tables, etc. If this is false and there are
objects still in the database the drop will fail.NoSuchObjectException
- No database of this name exists in the specified catalog and
ignoreUnknownDb is false.InvalidOperationException
- The database contains objects and cascade is false.MetaException
- something went wrong, usually either in the RDBMS or storage.org.apache.thrift.TException
- general thrift error.void dropDatabase(String catName, String dbName, boolean deleteData, boolean ignoreUnknownDb, boolean cascade) throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException
catName
- Catalog name. This can be null, in which case
Warehouse.DEFAULT_CATALOG_NAME
will be assumed.dbName
- database name.deleteData
- whether to drop the underlying HDFS directory.ignoreUnknownDb
- whether to ignore an attempt to drop a non-existant databasecascade
- whether to drop contained tables, etc. If this is false and there are
objects still in the database the drop will fail.NoSuchObjectException
- No database of this name exists in the specified catalog and
ignoreUnknownDb is false.InvalidOperationException
- The database contains objects and cascade is false.MetaException
- something went wrong, usually either in the RDBMS or storage.org.apache.thrift.TException
- general thrift error.default void dropDatabase(String catName, String dbName, boolean deleteData, boolean ignoreUnknownDb) throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException
dropDatabase(String, String, boolean, boolean, boolean)
with cascade = false.catName
- Catalog name. This can be null, in which case
Warehouse.DEFAULT_CATALOG_NAME
will be assumed.dbName
- database name.deleteData
- whether to drop the underlying HDFS directory.ignoreUnknownDb
- whether to ignore an attempt to drop a non-existant databaseNoSuchObjectException
- No database of this name exists in the specified catalog and
ignoreUnknownDb is false.InvalidOperationException
- The database contains objects and cascade is false.MetaException
- something went wrong, usually either in the RDBMS or storage.org.apache.thrift.TException
- general thrift error.default void dropDatabase(String catName, String dbName) throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException
dropDatabase(String, String, boolean, boolean, boolean)
with deleteData =
true, ignoreUnknownDb = false, cascade = false.catName
- Catalog name. This can be null, in which case
Warehouse.DEFAULT_CATALOG_NAME
will be assumed.dbName
- database name.NoSuchObjectException
- No database of this name exists in the specified catalog and
ignoreUnknownDb is false.InvalidOperationException
- The database contains objects and cascade is false.MetaException
- something went wrong, usually either in the RDBMS or storage.org.apache.thrift.TException
- general thrift error.void alterDatabase(String name, Database db) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
name
- database name.db
- new database object.NoSuchObjectException
- No database of this name exists in the specified catalog.MetaException
- something went wrong, usually in the RDBMS.org.apache.thrift.TException
- general thrift error.void alterDatabase(String catName, String dbName, Database newDb) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catName
- Catalog name. This can be null, in which case
Warehouse.DEFAULT_CATALOG_NAME
will be assumed.dbName
- database name.newDb
- new database object.NoSuchObjectException
- No database of this name exists in the specified catalog.MetaException
- something went wrong, usually in the RDBMS.org.apache.thrift.TException
- general thrift error.boolean dropPartition(String db_name, String tbl_name, List<String> part_vals, boolean deleteData) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
db_name
- database nametbl_name
- table namepart_vals
- partition values, in the same order as the partition keysdeleteData
- delete the underlying data or just delete the partition in metadataNoSuchObjectException
- partition does not existMetaException
- error accessing the RDBMS or the storage.org.apache.thrift.TException
- thrift transport errorboolean dropPartition(String catName, String db_name, String tbl_name, List<String> part_vals, boolean deleteData) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catName
- catalog name.db_name
- database nametbl_name
- table namepart_vals
- partition values, in the same order as the partition keysdeleteData
- delete the underlying data or just delete the partition in metadataNoSuchObjectException
- partition does not existMetaException
- error accessing the RDBMS or the storage.org.apache.thrift.TException
- thrift transport errorboolean dropPartition(String db_name, String tbl_name, List<String> part_vals, PartitionDropOptions options) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
db_name
- Name of the database.tbl_name
- Name of the table.part_vals
- Specification of the partitions being dropped.options
- PartitionDropOptions for the operation.NoSuchObjectException
- partition does not existMetaException
- error accessing the RDBMS or the storage.org.apache.thrift.TException
- thrift transport error.boolean dropPartition(String catName, String db_name, String tbl_name, List<String> part_vals, PartitionDropOptions options) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catName
- catalog name.db_name
- Name of the database.tbl_name
- Name of the table.part_vals
- Specification of the partitions being dropped.options
- PartitionDropOptions for the operation.NoSuchObjectException
- partition does not existMetaException
- error accessing the RDBMS or the storage.org.apache.thrift.TException
- thrift transport error.List<Partition> dropPartitions(String dbName, String tblName, List<ObjectPair<Integer,byte[]>> partExprs, boolean deleteData, boolean ifExists) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
dbName
- database name.tblName
- table name.partExprs
- I don't understand this fully, so can't completely explain it. The second
half of the object pair is an expression used to determine which partitions
to drop. The first half has something to do with archive level, but I
don't understand what. I'm also not sure what happens if you pass multiple
expressions.deleteData
- whether to delete the data as well as the metadata.ifExists
- if true, it is not an error if no partitions match the expression(s).NoSuchObjectException
- No partition matches the expression(s), and ifExists was false.MetaException
- error access the RDBMS or storage.org.apache.thrift.TException
- Thrift transport error.default List<Partition> dropPartitions(String catName, String dbName, String tblName, List<ObjectPair<Integer,byte[]>> partExprs, boolean deleteData, boolean ifExists) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catName
- catalog name.dbName
- database name.tblName
- table name.partExprs
- I don't understand this fully, so can't completely explain it. The second
half of the object pair is an expression used to determine which partitions
to drop. The first half has something to do with archive level, but I
don't understand what. I'm also not sure what happens if you pass multiple
expressions.deleteData
- whether to delete the data as well as the metadata.ifExists
- if true, it is not an error if no partitions match the expression(s).NoSuchObjectException
- No partition matches the expression(s), and ifExists was false.MetaException
- error access the RDBMS or storage.org.apache.thrift.TException
- Thrift transport error.@Deprecated List<Partition> dropPartitions(String dbName, String tblName, List<ObjectPair<Integer,byte[]>> partExprs, boolean deleteData, boolean ifExists, boolean needResults) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
dbName
- database name.tblName
- table name.partExprs
- I don't understand this fully, so can't completely explain it. The second
half of the object pair is an expression used to determine which partitions
to drop. The first half has something to do with archive level, but I
don't understand what. I'm also not sure what happens if you pass multiple
expressions.deleteData
- whether to delete the data as well as the metadata.ifExists
- if true, it is not an error if no partitions match the expression(s).needResults
- if true, the list of deleted partitions will be returned, if not, null
will be returned.NoSuchObjectException
- No partition matches the expression(s), and ifExists was false.MetaException
- error access the RDBMS or storage.org.apache.thrift.TException
- Thrift transport error.default List<Partition> dropPartitions(String catName, String dbName, String tblName, List<ObjectPair<Integer,byte[]>> partExprs, boolean deleteData, boolean ifExists, boolean needResults) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catName
- catalog name.dbName
- database name.tblName
- table name.partExprs
- I don't understand this fully, so can't completely explain it. The second
half of the object pair is an expression used to determine which partitions
to drop. The first half has something to do with archive level, but I
don't understand what. I'm also not sure what happens if you pass multiple
expressions.deleteData
- whether to delete the data as well as the metadata.ifExists
- if true, it is not an error if no partitions match the expression(s).needResults
- if true, the list of deleted partitions will be returned, if not, null
will be returned.NoSuchObjectException
- No partition matches the expression(s), and ifExists was false.MetaException
- error access the RDBMS or storage.org.apache.thrift.TException
- Thrift transport error.List<Partition> dropPartitions(String dbName, String tblName, List<ObjectPair<Integer,byte[]>> partExprs, PartitionDropOptions options) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
dbName
- Name of the databasetblName
- Name of the tablepartExprs
- Partition-specificationoptions
- Boolean options for dropping partitionsNoSuchObjectException
- No partition matches the expression(s), and ifExists was false.MetaException
- error access the RDBMS or storage.org.apache.thrift.TException
- On failureList<Partition> dropPartitions(String catName, String dbName, String tblName, List<ObjectPair<Integer,byte[]>> partExprs, PartitionDropOptions options) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catName
- catalog namedbName
- Name of the databasetblName
- Name of the tablepartExprs
- Partition-specificationoptions
- Boolean options for dropping partitionsNoSuchObjectException
- No partition matches the expression(s), and ifExists was false.MetaException
- error access the RDBMS or storage.org.apache.thrift.TException
- On failureboolean dropPartition(String db_name, String tbl_name, String name, boolean deleteData) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
db_name
- database name.tbl_name
- table name.name
- partition name.deleteData
- whether to delete the data or just the metadata.NoSuchObjectException
- no such partition.MetaException
- error accessing the RDBMS or storageorg.apache.thrift.TException
- thrift transport errorboolean dropPartition(String catName, String db_name, String tbl_name, String name, boolean deleteData) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catName
- catalog name.db_name
- database name.tbl_name
- table name.name
- partition name.deleteData
- whether to delete the data or just the metadata.NoSuchObjectException
- no such partition.MetaException
- error accessing the RDBMS or storageorg.apache.thrift.TException
- thrift transport errorvoid alter_partition(String dbName, String tblName, Partition newPart) throws InvalidOperationException, MetaException, org.apache.thrift.TException
dbName
- database of the old partitiontblName
- table name of the old partitionnewPart
- new partitionInvalidOperationException
- if the old partition does not existMetaException
- if error in updating metadataorg.apache.thrift.TException
- if error in communicating with metastore serverdefault void alter_partition(String catName, String dbName, String tblName, Partition newPart) throws InvalidOperationException, MetaException, org.apache.thrift.TException
catName
- catalog namedbName
- database of the old partitiontblName
- table name of the old partitionnewPart
- new partitionInvalidOperationException
- if the old partition does not existMetaException
- if error in updating metadataorg.apache.thrift.TException
- if error in communicating with metastore servervoid alter_partition(String dbName, String tblName, Partition newPart, EnvironmentContext environmentContext) throws InvalidOperationException, MetaException, org.apache.thrift.TException
dbName
- database of the old partitiontblName
- table name of the old partitionnewPart
- new partitionInvalidOperationException
- if the old partition does not existMetaException
- if error in updating metadataorg.apache.thrift.TException
- if error in communicating with metastore servervoid alter_partition(String catName, String dbName, String tblName, Partition newPart, EnvironmentContext environmentContext) throws InvalidOperationException, MetaException, org.apache.thrift.TException
catName
- catalog name.dbName
- database of the old partitiontblName
- table name of the old partitionnewPart
- new partitionInvalidOperationException
- if the old partition does not existMetaException
- if error in updating metadataorg.apache.thrift.TException
- if error in communicating with metastore servervoid alter_partitions(String dbName, String tblName, List<Partition> newParts) throws InvalidOperationException, MetaException, org.apache.thrift.TException
dbName
- database of the old partitiontblName
- table name of the old partitionnewParts
- list of partitionsInvalidOperationException
- if the old partition does not existMetaException
- if error in updating metadataorg.apache.thrift.TException
- if error in communicating with metastore servervoid alter_partitions(String dbName, String tblName, List<Partition> newParts, EnvironmentContext environmentContext) throws InvalidOperationException, MetaException, org.apache.thrift.TException
dbName
- database of the old partitiontblName
- table name of the old partitionnewParts
- list of partitionsenvironmentContext
- key value pairs to pass to alter function.InvalidOperationException
- if the old partition does not existMetaException
- if error in updating metadataorg.apache.thrift.TException
- if error in communicating with metastore serverdefault void alter_partitions(String catName, String dbName, String tblName, List<Partition> newParts) throws InvalidOperationException, MetaException, org.apache.thrift.TException
catName
- catalog name.dbName
- database of the old partitiontblName
- table name of the old partitionnewParts
- list of partitionsInvalidOperationException
- if the old partition does not existMetaException
- if error in updating metadataorg.apache.thrift.TException
- if error in communicating with metastore servervoid alter_partitions(String catName, String dbName, String tblName, List<Partition> newParts, EnvironmentContext environmentContext) throws InvalidOperationException, MetaException, org.apache.thrift.TException
catName
- catalog name.dbName
- database of the old partitiontblName
- table name of the old partitionnewParts
- list of partitionsenvironmentContext
- key value pairs to pass to alter function.InvalidOperationException
- if the old partition does not existMetaException
- if error in updating metadataorg.apache.thrift.TException
- if error in communicating with metastore servervoid renamePartition(String dbname, String tableName, List<String> part_vals, Partition newPart) throws InvalidOperationException, MetaException, org.apache.thrift.TException
dbname
- database of the old partitiontableName
- table name of the old partitionpart_vals
- values of the old partitionnewPart
- new partitionInvalidOperationException
- if srcFs and destFs are differentMetaException
- if error in updating metadataorg.apache.thrift.TException
- if error in communicating with metastore servervoid renamePartition(String catName, String dbname, String tableName, List<String> part_vals, Partition newPart) throws InvalidOperationException, MetaException, org.apache.thrift.TException
catName
- catalog name.dbname
- database of the old partitiontableName
- table name of the old partitionpart_vals
- values of the old partitionnewPart
- new partitionInvalidOperationException
- if srcFs and destFs are differentMetaException
- if error in updating metadataorg.apache.thrift.TException
- if error in communicating with metastore serverList<FieldSchema> getFields(String db, String tableName) throws MetaException, org.apache.thrift.TException, UnknownTableException, UnknownDBException
db
- database nametableName
- table nameUnknownTableException
- no such tableUnknownDBException
- no such databaseMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorList<FieldSchema> getFields(String catName, String db, String tableName) throws MetaException, org.apache.thrift.TException, UnknownTableException, UnknownDBException
catName
- catalog namedb
- database nametableName
- table nameUnknownTableException
- no such tableUnknownDBException
- no such databaseMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorList<FieldSchema> getSchema(String db, String tableName) throws MetaException, org.apache.thrift.TException, UnknownTableException, UnknownDBException
db
- database nametableName
- table nameUnknownTableException
- no such tableUnknownDBException
- no such databaseMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorList<FieldSchema> getSchema(String catName, String db, String tableName) throws MetaException, org.apache.thrift.TException, UnknownTableException, UnknownDBException
catName
- catalog namedb
- database nametableName
- table nameUnknownTableException
- no such tableUnknownDBException
- no such databaseMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorString getConfigValue(String name, String defaultValue) throws org.apache.thrift.TException, ConfigValSecurityException
name
- name of the configuration property to get the value ofdefaultValue
- the value to return if property with the given name doesn't existorg.apache.thrift.TException
ConfigValSecurityException
List<String> partitionNameToVals(String name) throws MetaException, org.apache.thrift.TException
name
- the partition name e.g. ("ds=2010-03-03/hr=12")MetaException
org.apache.thrift.TException
Map<String,String> partitionNameToSpec(String name) throws MetaException, org.apache.thrift.TException
name
- the partition name e.g. ("ds=2010-03-03/hr=12")MetaException
org.apache.thrift.TException
boolean updateTableColumnStatistics(ColumnStatistics statsObj) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException, InvalidInputException
statsObj
- NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
InvalidInputException
boolean updatePartitionColumnStatistics(ColumnStatistics statsObj) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException, InvalidInputException
statsObj
- NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
InvalidInputException
List<ColumnStatisticsObj> getTableColumnStatistics(String dbName, String tableName, List<String> colNames) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
getPartitionColumnStatistics(String, String, List, List)
.dbName
- database nametableName
- table namecolNames
- list of column namesNoSuchObjectException
- no such tableMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorList<ColumnStatisticsObj> getTableColumnStatistics(String catName, String dbName, String tableName, List<String> colNames) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
getPartitionColumnStatistics(String, String, String, List, List)
.catName
- catalog namedbName
- database nametableName
- table namecolNames
- list of column namesNoSuchObjectException
- no such tableMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorMap<String,List<ColumnStatisticsObj>> getPartitionColumnStatistics(String dbName, String tableName, List<String> partNames, List<String> colNames) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
dbName
- database nametableName
- table namepartNames
- partition names. Since these are names they should be of the form
"key1=value1[/key2=value2...]"colNames
- list of column namesNoSuchObjectException
- no such partitionMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorMap<String,List<ColumnStatisticsObj>> getPartitionColumnStatistics(String catName, String dbName, String tableName, List<String> partNames, List<String> colNames) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catName
- catalog namedbName
- database nametableName
- table namepartNames
- partition names. Since these are names they should be of the form
"key1=value1[/key2=value2...]"colNames
- list of column namesNoSuchObjectException
- no such partitionMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorboolean deletePartitionColumnStatistics(String dbName, String tableName, String partName, String colName) throws NoSuchObjectException, MetaException, InvalidObjectException, org.apache.thrift.TException, InvalidInputException
dbName
- database name.tableName
- table name.partName
- partition name.colName
- column name, or null for all columnsNoSuchObjectException
- no such partition existsInvalidObjectException
- error dropping the stats dataMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorInvalidInputException
- input is invalid or null.boolean deletePartitionColumnStatistics(String catName, String dbName, String tableName, String partName, String colName) throws NoSuchObjectException, MetaException, InvalidObjectException, org.apache.thrift.TException, InvalidInputException
catName
- catalog name.dbName
- database name.tableName
- table name.partName
- partition name.colName
- column name, or null for all columnsNoSuchObjectException
- no such partition existsInvalidObjectException
- error dropping the stats dataMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorInvalidInputException
- input is invalid or null.boolean deleteTableColumnStatistics(String dbName, String tableName, String colName) throws NoSuchObjectException, MetaException, InvalidObjectException, org.apache.thrift.TException, InvalidInputException
dbName
- database nametableName
- table namecolName
- column name, or null to drop stats for all columnsNoSuchObjectException
- No such tableMetaException
- error accessing the RDBMSInvalidObjectException
- error dropping the statsorg.apache.thrift.TException
- thrift transport errorInvalidInputException
- bad input, like a null table name.boolean deleteTableColumnStatistics(String catName, String dbName, String tableName, String colName) throws NoSuchObjectException, MetaException, InvalidObjectException, org.apache.thrift.TException, InvalidInputException
catName
- catalog namedbName
- database nametableName
- table namecolName
- column name, or null to drop stats for all columnsNoSuchObjectException
- No such tableMetaException
- error accessing the RDBMSInvalidObjectException
- error dropping the statsorg.apache.thrift.TException
- thrift transport errorInvalidInputException
- bad input, like a null table name.boolean create_role(Role role) throws MetaException, org.apache.thrift.TException
role
- role objectMetaException
org.apache.thrift.TException
boolean drop_role(String role_name) throws MetaException, org.apache.thrift.TException
role_name
- role nameMetaException
org.apache.thrift.TException
List<String> listRoleNames() throws MetaException, org.apache.thrift.TException
org.apache.thrift.TException
MetaException
boolean grant_role(String role_name, String user_name, PrincipalType principalType, String grantor, PrincipalType grantorType, boolean grantOption) throws MetaException, org.apache.thrift.TException
role_name
- user_name
- principalType
- grantor
- grantorType
- grantOption
- MetaException
org.apache.thrift.TException
boolean revoke_role(String role_name, String user_name, PrincipalType principalType, boolean grantOption) throws MetaException, org.apache.thrift.TException
role_name
- role nameuser_name
- user nameprincipalType
- MetaException
org.apache.thrift.TException
List<Role> list_roles(String principalName, PrincipalType principalType) throws MetaException, org.apache.thrift.TException
principalName
- principalType
- MetaException
org.apache.thrift.TException
PrincipalPrivilegeSet get_privilege_set(HiveObjectRef hiveObject, String user_name, List<String> group_names) throws MetaException, org.apache.thrift.TException
hiveObject
- user_name
- group_names
- MetaException
org.apache.thrift.TException
List<HiveObjectPrivilege> list_privileges(String principal_name, PrincipalType principal_type, HiveObjectRef hiveObject) throws MetaException, org.apache.thrift.TException
principal_name
- principal_type
- hiveObject
- MetaException
org.apache.thrift.TException
boolean grant_privileges(PrivilegeBag privileges) throws MetaException, org.apache.thrift.TException
privileges
- MetaException
org.apache.thrift.TException
boolean revoke_privileges(PrivilegeBag privileges, boolean grantOption) throws MetaException, org.apache.thrift.TException
privileges
- MetaException
org.apache.thrift.TException
boolean refresh_privileges(HiveObjectRef objToRefresh, String authorizer, PrivilegeBag grantPrivileges) throws MetaException, org.apache.thrift.TException
objToRefresh
- authorizer
- grantPrivileges
- MetaException
org.apache.thrift.TException
String getDelegationToken(String owner, String renewerKerberosPrincipalName) throws MetaException, org.apache.thrift.TException
owner
- the intended owner for the tokenrenewerKerberosPrincipalName
- MetaException
org.apache.thrift.TException
long renewDelegationToken(String tokenStrForm) throws MetaException, org.apache.thrift.TException
tokenStrForm
- MetaException
org.apache.thrift.TException
void cancelDelegationToken(String tokenStrForm) throws MetaException, org.apache.thrift.TException
tokenStrForm
- MetaException
org.apache.thrift.TException
String getTokenStrForm() throws IOException
IOException
boolean addToken(String tokenIdentifier, String delegationToken) throws org.apache.thrift.TException
org.apache.thrift.TException
boolean removeToken(String tokenIdentifier) throws org.apache.thrift.TException
org.apache.thrift.TException
String getToken(String tokenIdentifier) throws org.apache.thrift.TException
org.apache.thrift.TException
List<String> getAllTokenIdentifiers() throws org.apache.thrift.TException
org.apache.thrift.TException
int addMasterKey(String key) throws MetaException, org.apache.thrift.TException
MetaException
org.apache.thrift.TException
void updateMasterKey(Integer seqNo, String key) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
NoSuchObjectException
MetaException
org.apache.thrift.TException
boolean removeMasterKey(Integer keySeq) throws org.apache.thrift.TException
org.apache.thrift.TException
String[] getMasterKeys() throws org.apache.thrift.TException
org.apache.thrift.TException
void createFunction(Function func) throws InvalidObjectException, MetaException, org.apache.thrift.TException
func
- function specificationInvalidObjectException
- the function object is invalidMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorvoid alterFunction(String dbName, String funcName, Function newFunction) throws InvalidObjectException, MetaException, org.apache.thrift.TException
dbName
- database name.funcName
- function name.newFunction
- new function specification. This should be complete, not just the changes.InvalidObjectException
- the function object is invalidMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorvoid alterFunction(String catName, String dbName, String funcName, Function newFunction) throws InvalidObjectException, MetaException, org.apache.thrift.TException
catName
- catalog name.dbName
- database name.funcName
- function name.newFunction
- new function specification. This should be complete, not just the changes.InvalidObjectException
- the function object is invalidMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorvoid dropFunction(String dbName, String funcName) throws MetaException, NoSuchObjectException, InvalidObjectException, InvalidInputException, org.apache.thrift.TException
dbName
- database name.funcName
- function name.MetaException
- error accessing the RDBMSNoSuchObjectException
- no such functionInvalidObjectException
- not sure when this is thrownInvalidInputException
- not sure when this is thrownorg.apache.thrift.TException
- thrift transport errorvoid dropFunction(String catName, String dbName, String funcName) throws MetaException, NoSuchObjectException, InvalidObjectException, InvalidInputException, org.apache.thrift.TException
catName
- catalog name.dbName
- database name.funcName
- function name.MetaException
- error accessing the RDBMSNoSuchObjectException
- no such functionInvalidObjectException
- not sure when this is thrownInvalidInputException
- not sure when this is thrownorg.apache.thrift.TException
- thrift transport errorFunction getFunction(String dbName, String funcName) throws MetaException, org.apache.thrift.TException
dbName
- database name.funcName
- function name.MetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorFunction getFunction(String catName, String dbName, String funcName) throws MetaException, org.apache.thrift.TException
catName
- catalog name.dbName
- database name.funcName
- function name.MetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorList<String> getFunctions(String dbName, String pattern) throws MetaException, org.apache.thrift.TException
dbName
- database name.pattern
- to match. This is a java regex pattern.MetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorList<String> getFunctions(String catName, String dbName, String pattern) throws MetaException, org.apache.thrift.TException
catName
- catalog name.dbName
- database name.pattern
- to match. This is a java regex pattern.MetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorGetAllFunctionsResponse getAllFunctions() throws MetaException, org.apache.thrift.TException
MetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errororg.apache.hadoop.hive.common.ValidTxnList getValidTxns() throws org.apache.thrift.TException
org.apache.thrift.TException
org.apache.hadoop.hive.common.ValidTxnList getValidTxns(long currentTxn) throws org.apache.thrift.TException
currentTxn
- The current transaction of the caller. This will be removed from the
exceptions list so that the caller sees records from his own transaction.org.apache.thrift.TException
org.apache.hadoop.hive.common.ValidWriteIdList getValidWriteIds(String fullTableName) throws org.apache.thrift.TException
fullTableName
- full table name of format <db_name>.<table_name>org.apache.thrift.TException
List<TableValidWriteIds> getValidWriteIds(List<String> tablesList, String validTxnList) throws org.apache.thrift.TException
tablesList
- list of tables (format: <db_name><table_name>) read from the current transaction
for which needs to populate the valid write idsvalidTxnList
- snapshot of valid txns for the current txnorg.apache.thrift.TException
long openTxn(String user) throws org.apache.thrift.TException
user
- User who is opening this transaction. This is the Hive user,
not necessarily the OS user. It is assumed that this user has already been
authenticated and authorized at this point.org.apache.thrift.TException
List<Long> replOpenTxn(String replPolicy, List<Long> srcTxnIds, String user) throws org.apache.thrift.TException
replPolicy
- The replication policy to uniquely identify the source cluster.srcTxnIds
- The list of transaction ids at the source clusteruser
- The user who has fired the repl load command.org.apache.thrift.TException
OpenTxnsResponse openTxns(String user, int numTxns) throws org.apache.thrift.TException
Increasing the number of transactions requested in the batch will allow applications that stream data into Hive to place more commits in a single file, thus reducing load on the namenode and making reads of the data more efficient. However, opening more transactions in a batch will also result in readers needing to keep a larger list of open transactions to ignore, potentially slowing their reads. Users will need to test in their system to understand the optimal number of transactions to request in a batch.
user
- User who is opening this transaction. This is the Hive user,
not necessarily the OS user. It is assumed that this user has already been
authenticated and authorized at this point.numTxns
- number of requested transactions to openorg.apache.thrift.TException
void rollbackTxn(long txnid) throws NoSuchTxnException, org.apache.thrift.TException
txnid
- id of transaction to be rolled back.NoSuchTxnException
- if the requested transaction does not exist.
Note that this can result from the transaction having timed out and been
deleted.org.apache.thrift.TException
void replRollbackTxn(long srcTxnid, String replPolicy) throws NoSuchTxnException, org.apache.thrift.TException
srcTxnid
- id of transaction at source while is rolled back and to be replicated.replPolicy
- the replication policy to identify the source clusterNoSuchTxnException
- if the requested transaction does not exist.
Note that this can result from the transaction having timed out and been
deleted.org.apache.thrift.TException
void commitTxn(long txnid) throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
txnid
- id of transaction to be committed.NoSuchTxnException
- if the requested transaction does not exist.
This can result fro the transaction having timed out and been deleted by
the compactor.TxnAbortedException
- if the requested transaction has been
aborted. This can result from the transaction timing out.org.apache.thrift.TException
void replCommitTxn(long srcTxnid, String replPolicy) throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
srcTxnid
- id of transaction at source which is committed and to be replicated.replPolicy
- the replication policy to identify the source clusterNoSuchTxnException
- if the requested transaction does not exist.
This can result fro the transaction having timed out and been deleted by
the compactor.TxnAbortedException
- if the requested transaction has been
aborted. This can result from the transaction timing out.org.apache.thrift.TException
void abortTxns(List<Long> txnids) throws org.apache.thrift.TException
org.apache.thrift.TException
long allocateTableWriteId(long txnId, String dbName, String tableName) throws org.apache.thrift.TException
txnId
- id of transaction to which the allocated write ID to be associated.dbName
- name of DB in which the table belongs.tableName
- table to which the write ID to be allocatedorg.apache.thrift.TException
void replTableWriteIdState(String validWriteIdList, String dbName, String tableName, List<String> partNames) throws org.apache.thrift.TException
validWriteIdList
- Snapshot of writeid list when the table/partition is dumped.dbName
- Database nametableName
- Table which is written.partNames
- List of partitions being written.org.apache.thrift.TException
- in case of failure to replicate the writeid stateList<TxnToWriteId> allocateTableWriteIdsBatch(List<Long> txnIds, String dbName, String tableName) throws org.apache.thrift.TException
txnIds
- ids of transaction batchto which the allocated write ID to be associated.dbName
- name of DB in which the table belongs.tableName
- table to which the write ID to be allocatedorg.apache.thrift.TException
List<TxnToWriteId> replAllocateTableWriteIdsBatch(String dbName, String tableName, String replPolicy, List<TxnToWriteId> srcTxnToWriteIdList) throws org.apache.thrift.TException
dbName
- name of DB in which the table belongs.tableName
- table to which the write ID to be allocatedreplPolicy
- Used by replication task to identify the source cluster.srcTxnToWriteIdList
- List of txn to write id map sent from the source cluster.org.apache.thrift.TException
GetOpenTxnsInfoResponse showTxns() throws org.apache.thrift.TException
getValidTxns()
.org.apache.thrift.TException
LockResponse lock(LockRequest request) throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
If the operation requires a transaction (INSERT, UPDATE, or DELETE) that transaction id must be provided as part this lock request. All locks associated with a transaction will be released when that transaction is committed or rolled back.
*Once a lock is acquired, heartbeat(long, long)
must be called
on a regular basis to avoid the lock being timed out by the system.
request
- The lock request. LockRequestBuilder
can be used
construct this request.checkLock(long)
before proceeding. All components of the lock
will have the same state.NoSuchTxnException
- if the requested transaction does not exist.
This can result fro the transaction having timed out and been deleted by
the compactor.TxnAbortedException
- if the requested transaction has been
aborted. This can result from the transaction timing out.org.apache.thrift.TException
LockResponse checkLock(long lockid) throws NoSuchTxnException, TxnAbortedException, NoSuchLockException, org.apache.thrift.TException
lock(org.apache.hadoop.hive.metastore.api.LockRequest)
call.
Once a lock is acquired, heartbeat(long, long)
must be called
on a regular basis to avoid the lock being timed out by the system.lockid
- lock id returned by lock().NoSuchTxnException
- if the requested transaction does not exist.
This can result fro the transaction having timed out and been deleted by
the compactor.TxnAbortedException
- if the requested transaction has been
aborted. This can result from the transaction timing out.NoSuchLockException
- if the requested lockid does not exist.
This can result from the lock timing out and being unlocked by the system.org.apache.thrift.TException
void unlock(long lockid) throws NoSuchLockException, TxnOpenException, org.apache.thrift.TException
lockid
- lock id returned by
lock(org.apache.hadoop.hive.metastore.api.LockRequest)
NoSuchLockException
- if the requested lockid does not exist.
This can result from the lock timing out and being unlocked by the system.TxnOpenException
- if the locks are are associated with a
transaction.org.apache.thrift.TException
@Deprecated ShowLocksResponse showLocks() throws org.apache.thrift.TException
org.apache.thrift.TException
ShowLocksResponse showLocks(ShowLocksRequest showLocksRequest) throws org.apache.thrift.TException
showLocksRequest
- SHOW LOCK requestorg.apache.thrift.TException
void heartbeat(long txnid, long lockid) throws NoSuchLockException, NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
txnid
- the id of the open transaction. If no transaction is open
(it is a DDL or query) then this can be set to 0.lockid
- the id of the locks obtained. If no locks have been
obtained then this can be set to 0.NoSuchTxnException
- if the requested transaction does not exist.
This can result fro the transaction having timed out and been deleted by
the compactor.TxnAbortedException
- if the requested transaction has been
aborted. This can result from the transaction timing out.NoSuchLockException
- if the requested lockid does not exist.
This can result from the lock timing out and being unlocked by the system.org.apache.thrift.TException
HeartbeatTxnRangeResponse heartbeatTxnRange(long min, long max) throws org.apache.thrift.TException
heartbeat(long, long)
.min
- minimum transaction id to heartbeat, inclusivemax
- maximum transaction id to heartbeat, inclusiveorg.apache.thrift.TException
@Deprecated void compact(String dbname, String tableName, String partitionName, CompactionType type) throws org.apache.thrift.TException
dbname
- Name of the database the table is in. If null, this will be assumed to be
'default'.tableName
- Name of the table to be compacted. This cannot be null. If partitionName
is null, this must be a non-partitioned table.partitionName
- Name of the partition to be compactedtype
- Whether this is a major or minor compaction.org.apache.thrift.TException
@Deprecated void compact(String dbname, String tableName, String partitionName, CompactionType type, Map<String,String> tblproperties) throws org.apache.thrift.TException
org.apache.thrift.TException
CompactionResponse compact2(String dbname, String tableName, String partitionName, CompactionType type, Map<String,String> tblproperties) throws org.apache.thrift.TException
dbname
- Name of the database the table is in. If null, this will be assumed to be
'default'.tableName
- Name of the table to be compacted. This cannot be null. If partitionName
is null, this must be a non-partitioned table.partitionName
- Name of the partition to be compactedtype
- Whether this is a major or minor compaction.tblproperties
- the list of tblproperties to override for this compact. Can be null.org.apache.thrift.TException
ShowCompactResponse showCompactions() throws org.apache.thrift.TException
org.apache.thrift.TException
@Deprecated void addDynamicPartitions(long txnId, long writeId, String dbName, String tableName, List<String> partNames) throws org.apache.thrift.TException
org.apache.thrift.TException
void addDynamicPartitions(long txnId, long writeId, String dbName, String tableName, List<String> partNames, DataOperationType operationType) throws org.apache.thrift.TException
txnId
- id of the transactionwriteId
- table write id for this txndbName
- database nametableName
- table namepartNames
- partition name, as constructed by Warehouse.makePartNameorg.apache.thrift.TException
void insertTable(Table table, boolean overwrite) throws MetaException
table
- table nameoverwrite
- true if the insert is overwriteMetaException
@InterfaceAudience.LimitedPrivate(value="HCatalog") NotificationEventResponse getNextNotification(long lastEventId, int maxEvents, IMetaStoreClient.NotificationFilter filter) throws org.apache.thrift.TException
lastEventId
- The last event id that was consumed by this reader. The returned
notifications will start at the next eventId available after this eventId.maxEvents
- Maximum number of events to return. If < 1, then all available events will
be returned.filter
- User provided filter to remove unwanted events. If null, all events will be
returned.org.apache.thrift.TException
@InterfaceAudience.LimitedPrivate(value="HCatalog") CurrentNotificationEventId getCurrentNotificationEventId() throws org.apache.thrift.TException
org.apache.thrift.TException
@InterfaceAudience.LimitedPrivate(value="HCatalog") NotificationEventsCountResponse getNotificationEventsCount(NotificationEventsCountRequest rqst) throws org.apache.thrift.TException
org.apache.thrift.TException
@InterfaceAudience.LimitedPrivate(value="Apache Hive, HCatalog") FireEventResponse fireListenerEvent(FireEventRequest request) throws org.apache.thrift.TException
request
- org.apache.thrift.TException
GetPrincipalsInRoleResponse get_principals_in_role(GetPrincipalsInRoleRequest getPrincRoleReq) throws MetaException, org.apache.thrift.TException
getPrincRoleReq
- MetaException
org.apache.thrift.TException
GetRoleGrantsForPrincipalResponse get_role_grants_for_principal(GetRoleGrantsForPrincipalRequest getRolePrincReq) throws MetaException, org.apache.thrift.TException
getRolePrincReq
- MetaException
org.apache.thrift.TException
AggrStats getAggrColStatsFor(String dbName, String tblName, List<String> colNames, List<String> partName) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
dbName
- database nametblName
- table namecolNames
- list of column namespartName
- list of partition names (not values).NoSuchObjectException
- no such tableMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport exceptionAggrStats getAggrColStatsFor(String catName, String dbName, String tblName, List<String> colNames, List<String> partNames) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
catName
- catalog namedbName
- database nametblName
- table namecolNames
- list of column namespartNames
- list of partition names (not values).NoSuchObjectException
- no such tableMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport exceptionboolean setPartitionColumnStatistics(SetPartitionsStatsRequest request) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException, InvalidInputException
request
- request object, contains all the table, partition, and statistics informationNoSuchObjectException
- the table, partition, or columns specified do not exist.InvalidObjectException
- the stats object is not valid.MetaException
- error accessing the RDBMS.org.apache.thrift.TException
- thrift transport error.InvalidInputException
- the input is invalid (eg, a null table name)void flushCache()
Iterable<Map.Entry<Long,ByteBuffer>> getFileMetadata(List<Long> fileIds) throws org.apache.thrift.TException
org.apache.thrift.TException
Iterable<Map.Entry<Long,MetadataPpdResult>> getFileMetadataBySarg(List<Long> fileIds, ByteBuffer sarg, boolean doGetFooters) throws org.apache.thrift.TException
org.apache.thrift.TException
void clearFileMetadata(List<Long> fileIds) throws org.apache.thrift.TException
org.apache.thrift.TException
void putFileMetadata(List<Long> fileIds, List<ByteBuffer> metadata) throws org.apache.thrift.TException
org.apache.thrift.TException
boolean isSameConfObj(org.apache.hadoop.conf.Configuration c)
boolean cacheFileMetadata(String dbName, String tableName, String partName, boolean allParts) throws org.apache.thrift.TException
org.apache.thrift.TException
List<SQLPrimaryKey> getPrimaryKeys(PrimaryKeysRequest request) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
request
- Request infoMetaException
- error reading the RDBMSNoSuchObjectException
- no primary key exists on this table, or maybe no such tableorg.apache.thrift.TException
- thrift transport errorList<SQLForeignKey> getForeignKeys(ForeignKeysRequest request) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
request
- Request infoMetaException
- error reading the RDBMSNoSuchObjectException
- no foreign key exists on this table, or maybe no such tableorg.apache.thrift.TException
- thrift transport errorList<SQLUniqueConstraint> getUniqueConstraints(UniqueConstraintsRequest request) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
request
- Request infoMetaException
- error reading the RDBMSNoSuchObjectException
- no unique constraint on this table, or maybe no such tableorg.apache.thrift.TException
- thrift transport errorList<SQLNotNullConstraint> getNotNullConstraints(NotNullConstraintsRequest request) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
request
- Request infoMetaException
- error reading the RDBMSNoSuchObjectException
- no not null constraint on this table, or maybe no such tableorg.apache.thrift.TException
- thrift transport errorList<SQLDefaultConstraint> getDefaultConstraints(DefaultConstraintsRequest request) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
MetaException
NoSuchObjectException
org.apache.thrift.TException
List<SQLCheckConstraint> getCheckConstraints(CheckConstraintsRequest request) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
MetaException
NoSuchObjectException
org.apache.thrift.TException
void createTableWithConstraints(Table tTbl, List<SQLPrimaryKey> primaryKeys, List<SQLForeignKey> foreignKeys, List<SQLUniqueConstraint> uniqueConstraints, List<SQLNotNullConstraint> notNullConstraints, List<SQLDefaultConstraint> defaultConstraints, List<SQLCheckConstraint> checkConstraints) throws AlreadyExistsException, InvalidObjectException, MetaException, NoSuchObjectException, org.apache.thrift.TException
AlreadyExistsException
InvalidObjectException
MetaException
NoSuchObjectException
org.apache.thrift.TException
void dropConstraint(String dbName, String tableName, String constraintName) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
dbName
- database nametableName
- table nameconstraintName
- name of the constraintMetaException
- RDBMS access errorNoSuchObjectException
- no such constraint existsorg.apache.thrift.TException
- thrift transport errorvoid dropConstraint(String catName, String dbName, String tableName, String constraintName) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
catName
- catalog namedbName
- database nametableName
- table nameconstraintName
- name of the constraintMetaException
- RDBMS access errorNoSuchObjectException
- no such constraint existsorg.apache.thrift.TException
- thrift transport errorvoid addPrimaryKey(List<SQLPrimaryKey> primaryKeyCols) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
primaryKeyCols
- Primary key columns.MetaException
- error reading or writing to the RDBMS or a primary key already existsNoSuchObjectException
- no such table existsorg.apache.thrift.TException
- thrift transport errorvoid addForeignKey(List<SQLForeignKey> foreignKeyCols) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
foreignKeyCols
- Foreign key definitionMetaException
- error reading or writing to the RDBMS or foreign key already existsNoSuchObjectException
- one of the tables in the foreign key does not exist.org.apache.thrift.TException
- thrift transport errorvoid addUniqueConstraint(List<SQLUniqueConstraint> uniqueConstraintCols) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
uniqueConstraintCols
- Unique constraint definitionMetaException
- error reading or writing to the RDBMS or unique constraint already existsNoSuchObjectException
- no such tableorg.apache.thrift.TException
- thrift transport errorvoid addNotNullConstraint(List<SQLNotNullConstraint> notNullConstraintCols) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
notNullConstraintCols
- Notnull constraint definitionMetaException
- error reading or writing to the RDBMS or not null constraint already
existsNoSuchObjectException
- no such tableorg.apache.thrift.TException
- thrift transport errorvoid addDefaultConstraint(List<SQLDefaultConstraint> defaultConstraints) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
MetaException
NoSuchObjectException
org.apache.thrift.TException
void addCheckConstraint(List<SQLCheckConstraint> checkConstraints) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
MetaException
NoSuchObjectException
org.apache.thrift.TException
String getMetastoreDbUuid() throws MetaException, org.apache.thrift.TException
MetaException
- if HMS is not able to fetch the UUID or if there are multiple UUIDs found in the databaseorg.apache.thrift.TException
- in case of Thrift errorsvoid createResourcePlan(WMResourcePlan resourcePlan, String copyFromName) throws InvalidObjectException, MetaException, org.apache.thrift.TException
InvalidObjectException
MetaException
org.apache.thrift.TException
WMFullResourcePlan getResourcePlan(String resourcePlanName) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
NoSuchObjectException
MetaException
org.apache.thrift.TException
List<WMResourcePlan> getAllResourcePlans() throws NoSuchObjectException, MetaException, org.apache.thrift.TException
NoSuchObjectException
MetaException
org.apache.thrift.TException
void dropResourcePlan(String resourcePlanName) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
NoSuchObjectException
MetaException
org.apache.thrift.TException
WMFullResourcePlan alterResourcePlan(String resourcePlanName, WMNullableResourcePlan resourcePlan, boolean canActivateDisabled, boolean isForceDeactivate, boolean isReplace) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
WMFullResourcePlan getActiveResourcePlan() throws MetaException, org.apache.thrift.TException
MetaException
org.apache.thrift.TException
WMValidateResourcePlanResponse validateResourcePlan(String resourcePlanName) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
void createWMTrigger(WMTrigger trigger) throws InvalidObjectException, MetaException, org.apache.thrift.TException
InvalidObjectException
MetaException
org.apache.thrift.TException
void alterWMTrigger(WMTrigger trigger) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
void dropWMTrigger(String resourcePlanName, String triggerName) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
NoSuchObjectException
MetaException
org.apache.thrift.TException
List<WMTrigger> getTriggersForResourcePlan(String resourcePlan) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
NoSuchObjectException
MetaException
org.apache.thrift.TException
void createWMPool(WMPool pool) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
void alterWMPool(WMNullablePool pool, String poolPath) throws NoSuchObjectException, InvalidObjectException, org.apache.thrift.TException
NoSuchObjectException
InvalidObjectException
org.apache.thrift.TException
void dropWMPool(String resourcePlanName, String poolPath) throws org.apache.thrift.TException
org.apache.thrift.TException
void createOrUpdateWMMapping(WMMapping mapping, boolean isUpdate) throws org.apache.thrift.TException
org.apache.thrift.TException
void dropWMMapping(WMMapping mapping) throws org.apache.thrift.TException
org.apache.thrift.TException
void createOrDropTriggerToPoolMapping(String resourcePlanName, String triggerName, String poolPath, boolean shouldDrop) throws AlreadyExistsException, NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
AlreadyExistsException
NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
void createISchema(ISchema schema) throws org.apache.thrift.TException
schema
- schema to createAlreadyExistsException
- if a schema of this name already existsNoSuchObjectException
- database references by this schema does not existMetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorvoid alterISchema(String catName, String dbName, String schemaName, ISchema newSchema) throws org.apache.thrift.TException
catName
- catalog namedbName
- database the schema is inschemaName
- name of the schemanewSchema
- altered schema objectNoSuchObjectException
- no schema with this name could be foundMetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorISchema getISchema(String catName, String dbName, String name) throws org.apache.thrift.TException
catName
- catalog namedbName
- database the schema is inname
- name of the schemaNoSuchObjectException
- no schema matching this name existsMetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorvoid dropISchema(String catName, String dbName, String name) throws org.apache.thrift.TException
catName
- catalog namedbName
- database the schema is inname
- name of the schema to dropNoSuchObjectException
- no schema with this name could be foundInvalidOperationException
- attempt to drop a schema that has versionsMetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorvoid addSchemaVersion(SchemaVersion schemaVersion) throws org.apache.thrift.TException
schemaVersion
- version object to addAlreadyExistsException
- a version of this schema with the same version id already existsNoSuchObjectException
- no schema with this name could be foundMetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorSchemaVersion getSchemaVersion(String catName, String dbName, String schemaName, int version) throws org.apache.thrift.TException
dbName
- database the schema is inschemaName
- name of the schemaversion
- version of the schemaNoSuchObjectException
- no schema matching this name and version existsMetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorSchemaVersion getSchemaLatestVersion(String catName, String dbName, String schemaName) throws org.apache.thrift.TException
catName
- catalog namedbName
- database the schema is inschemaName
- name of the schemaNoSuchObjectException
- no versions of schema matching this name existMetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorList<SchemaVersion> getSchemaAllVersions(String catName, String dbName, String schemaName) throws org.apache.thrift.TException
catName
- catalog namedbName
- database the schema is inschemaName
- name of the schema.NoSuchObjectException
- no versions of schema matching this name existMetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorvoid dropSchemaVersion(String catName, String dbName, String schemaName, int version) throws org.apache.thrift.TException
catName
- catalog namedbName
- database the schema is inschemaName
- name of the schemaversion
- version of the schemaNoSuchObjectException
- no matching version of the schema could be foundMetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorFindSchemasByColsResp getSchemaByCols(FindSchemasByColsRqst rqst) throws org.apache.thrift.TException
rqst
- query, this can include column names, namespaces (actually stored in the
description field in FieldSchema), and types.MetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorvoid mapSchemaVersionToSerde(String catName, String dbName, String schemaName, int version, String serdeName) throws org.apache.thrift.TException
catName
- catalog namedbName
- database the schema is inschemaName
- name of the schemaversion
- version of the schemaserdeName
- name of the serdeNoSuchObjectException
- no matching version of the schema could be found or no serde
of the provided name could be foundMetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorvoid setSchemaVersionState(String catName, String dbName, String schemaName, int version, SchemaVersionState state) throws org.apache.thrift.TException
catName
- catalog namedbName
- database the schema is inschemaName
- name of the schemaversion
- version of the schemastate
- state to set the schema tooNoSuchObjectException
- no matching version of the schema could be foundInvalidOperationException
- attempt to make a state change that is not validMetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorvoid addSerDe(SerDeInfo serDeInfo) throws org.apache.thrift.TException
serDeInfo
- serde to addAlreadyExistsException
- serde of this name already existsMetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorSerDeInfo getSerDe(String serDeName) throws org.apache.thrift.TException
serDeName
- name of the serdeNoSuchObjectException
- no serde with this name exists.MetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorLockResponse lockMaterializationRebuild(String dbName, String tableName, long txnId) throws org.apache.thrift.TException
dbName
- db name for the materialized viewtableName
- table name for the materialized viewtxnId
- transaction id for the rebuildorg.apache.thrift.TException
boolean heartbeatLockMaterializationRebuild(String dbName, String tableName, long txnId) throws org.apache.thrift.TException
dbName
- db name for the materialized viewtableName
- table name for the materialized viewtxnId
- transaction id for the rebuildorg.apache.thrift.TException
void addRuntimeStat(RuntimeStat stat) throws org.apache.thrift.TException
org.apache.thrift.TException
List<RuntimeStat> getRuntimeStats(int maxWeight, int maxCreateTime) throws org.apache.thrift.TException
org.apache.thrift.TException
Copyright © 2022 The Apache Software Foundation. All rights reserved.