@InterfaceAudience.Public @InterfaceStability.Evolving public class HiveMetaStoreClient extends Object implements IMetaStoreClient, AutoCloseable
Modifier and Type | Class and Description |
---|---|
static class |
HiveMetaStoreClient.MetastoreMapIterable<K,V> |
IMetaStoreClient.IncompatibleMetastoreException, IMetaStoreClient.NotificationFilter
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.conf.Configuration |
conf |
protected static org.slf4j.Logger |
LOG |
static ClientCapabilities |
TEST_VERSION |
static ClientCapabilities |
VERSION
Capabilities of the current client.
|
Constructor and Description |
---|
HiveMetaStoreClient(org.apache.hadoop.conf.Configuration conf) |
HiveMetaStoreClient(org.apache.hadoop.conf.Configuration conf,
HiveMetaHookLoader hookLoader) |
HiveMetaStoreClient(org.apache.hadoop.conf.Configuration conf,
HiveMetaHookLoader hookLoader,
Boolean allowEmbedded) |
Modifier and Type | Method and Description |
---|---|
void |
abortTxns(List<Long> txnids)
Abort a list of transactions.
|
Partition |
add_partition(Partition new_part)
Add a partition to the table.
|
Partition |
add_partition(Partition new_part,
EnvironmentContext envContext) |
int |
add_partitions_pspec(PartitionSpecProxy partitionSpec)
Add a partitions using a spec proxy.
|
int |
add_partitions(List<Partition> new_parts)
Add partitions to the table.
|
List<Partition> |
add_partitions(List<Partition> parts,
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.
|
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
|
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
|
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 dbname,
String tbl_name,
Table new_tbl,
EnvironmentContext envContext)
Alter a table.
|
void |
alter_table(String catName,
String dbName,
String tblName,
Table newTable,
EnvironmentContext envContext)
Alter a table.
|
void |
alter_table(String dbname,
String tbl_name,
Table new_tbl)
Alter a table
|
void |
alter_table(String defaultDatabaseName,
String tblName,
Table table,
boolean cascade) |
void |
alterCatalog(String catalogName,
Catalog newCatalog)
Alter an existing catalog.
|
void |
alterDatabase(String dbName,
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 db_name,
String table_name,
List<String> part_vals)
/**
Add a partition to a table and get back the resulting Partition object.
|
Partition |
appendPartition(String dbName,
String tableName,
List<String> partVals,
EnvironmentContext ec)
Deprecated.
|
Partition |
appendPartition(String dbName,
String tableName,
String partName)
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.
|
Partition |
appendPartitionByName(String dbName,
String tableName,
String partName) |
Partition |
appendPartitionByName(String dbName,
String tableName,
String partName,
EnvironmentContext envContext) |
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
IMetaStoreClient.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) |
protected void |
create_table_with_environment_context(Table tbl,
EnvironmentContext envContext) |
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 |
createTable(Table tbl,
EnvironmentContext envContext) |
void |
createTableWithConstraints(Table tbl,
List<SQLPrimaryKey> primaryKeys,
List<SQLForeignKey> foreignKeys,
List<SQLUniqueConstraint> uniqueConstraints,
List<SQLNotNullConstraint> notNullConstraints,
List<SQLDefaultConstraint> defaultConstraints,
List<SQLCheckConstraint> checkConstraints) |
boolean |
createType(Type type) |
void |
createWMPool(WMPool pool) |
void |
createWMTrigger(WMTrigger trigger) |
protected Partition |
deepCopy(Partition partition) |
protected PrincipalPrivilegeSet |
deepCopy(PrincipalPrivilegeSet pps) |
protected Table |
deepCopy(Table table) |
protected List<FieldSchema> |
deepCopyFieldSchemas(List<FieldSchema> schemas) |
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 roleName) |
protected void |
drop_table_with_environment_context(String catName,
String dbname,
String name,
boolean deleteData,
EnvironmentContext envContext) |
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.
|
void |
dropDatabase(String catalogName,
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 dbName,
String tableName,
List<String> partVals)
Deprecated.
|
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,
EnvironmentContext env_context)
Deprecated.
|
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 dbName,
String tableName,
String partName,
boolean deleteData)
Drop a partition.
|
boolean |
dropPartition(String dbName,
String tableName,
String partName,
boolean dropData,
EnvironmentContext ec)
Deprecated.
|
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.
|
boolean |
dropPartitionByName(String dbName,
String tableName,
String partName,
boolean deleteData) |
boolean |
dropPartitionByName(String dbName,
String tableName,
String partName,
boolean deleteData,
EnvironmentContext envContext) |
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 needResult)
Drop partitions based on an expression.
|
List<Partition> |
dropPartitions(String dbName,
String tblName,
List<ObjectPair<Integer,byte[]>> partExprs,
PartitionDropOptions options)
Generalization of dropPartitions(),
|
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 name)
Drop the table.
|
void |
dropTable(String dbname,
String name,
boolean deleteData,
boolean ignoreUnknownTab)
Drop the table.
|
void |
dropTable(String dbname,
String name,
boolean deleteData,
boolean ignoreUnknownTab,
boolean ifPurge)
Drop the table.
|
void |
dropTable(String catName,
String dbName,
String tableName,
boolean deleteData,
boolean ignoreUnknownTable,
boolean ifPurge)
Drop a table.
|
void |
dropTable(String catName,
String dbname,
String name,
boolean deleteData,
boolean ignoreUnknownTab,
EnvironmentContext envContext)
Drop the table and choose whether to: delete the underlying table data;
throw if the table doesn't exist; save the data in the trash.
|
boolean |
dropType(String type) |
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 destinationTableName)
Exchange the partition between two tables
|
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 destinationTableName)
Exchange the partitions between two tables
|
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 rqst)
Request that the metastore fire an event.
|
void |
flushCache()
Flush any catalog objects held by the metastore implementation.
|
GetPrincipalsInRoleResponse |
get_principals_in_role(GetPrincipalsInRoleRequest req)
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 userName,
List<String> groupNames)
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> partNames)
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 req) |
String |
getConfigValue(String name,
String defaultValue) |
CurrentNotificationEventId |
getCurrentNotificationEventId()
Get the last used notification event id.
|
Database |
getDatabase(String name)
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 req) |
String |
getDelegationToken(String renewerKerberosPrincipalName) |
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 req)
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 req)
Get a not null constraint for a table.
|
int |
getNumPartitionsByFilter(String db_name,
String tbl_name,
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 db_name,
String tbl_name,
List<String> part_vals)
Get a partition.
|
Partition |
getPartition(String db,
String tableName,
String partName)
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 db_name,
String tbl_name,
List<String> part_vals,
String user_name,
List<String> group_names)
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 req)
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 name)
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) |
org.apache.thrift.transport.TTransport |
getTTransport() |
Type |
getType(String name) |
Map<String,Type> |
getTypeAll(String name) |
List<SQLUniqueConstraint> |
getUniqueConstraints(UniqueConstraintsRequest req)
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 roleName,
String userName,
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 principalName,
PrincipalType principalType,
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 dbName,
String tblName,
short max)
List Names of partitions in a table.
|
List<String> |
listPartitionNames(String catName,
String dbName,
String tableName,
int maxParts)
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 db_name,
String tbl_name,
List<String> part_vals,
short max_parts,
String user_name,
List<String> group_names)
List partitions along with privilege information for a user or groups
|
List<Partition> |
listPartitionsWithAuthInfo(String db_name,
String tbl_name,
short max_parts,
String user_name,
List<String> group_names)
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.
|
static IMetaStoreClient |
newSynchronizedClient(IMetaStoreClient client)
Creates a synchronized wrapper for any
IMetaStoreClient . |
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 roleName,
String userName,
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 request)
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
alter_partition, alter_partitions, alter_table, dropDatabase, dropDatabase, dropPartitions, dropPartitions, dropTable, dropTable
public static final ClientCapabilities VERSION
public static final ClientCapabilities TEST_VERSION
protected final org.apache.hadoop.conf.Configuration conf
protected static final org.slf4j.Logger LOG
public HiveMetaStoreClient(org.apache.hadoop.conf.Configuration conf) throws MetaException
MetaException
public HiveMetaStoreClient(org.apache.hadoop.conf.Configuration conf, HiveMetaHookLoader hookLoader) throws MetaException
MetaException
public HiveMetaStoreClient(org.apache.hadoop.conf.Configuration conf, HiveMetaHookLoader hookLoader, Boolean allowEmbedded) throws MetaException
MetaException
public org.apache.thrift.transport.TTransport getTTransport()
public boolean isLocalMetaStore()
IMetaStoreClient
isLocalMetaStore
in interface IMetaStoreClient
public boolean isCompatibleWith(org.apache.hadoop.conf.Configuration conf)
IMetaStoreClient
isCompatibleWith
in interface IMetaStoreClient
public void setHiveAddedJars(String addedJars)
IMetaStoreClient
setHiveAddedJars
in interface IMetaStoreClient
addedJars
- the hive.added.jars.path. It is qualified paths separated by commas.public void reconnect() throws MetaException
IMetaStoreClient
reconnect
in interface IMetaStoreClient
MetaException
public void alter_table(String dbname, String tbl_name, Table new_tbl) throws org.apache.thrift.TException
IMetaStoreClient
alter_table
in interface IMetaStoreClient
dbname
- database nametbl_name
- table namenew_tbl
- 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 exceptionpublic void alter_table(String defaultDatabaseName, String tblName, Table table, boolean cascade) throws org.apache.thrift.TException
alter_table
in interface IMetaStoreClient
org.apache.thrift.TException
public void alter_table_with_environmentContext(String dbname, String tbl_name, Table new_tbl, EnvironmentContext envContext) throws InvalidOperationException, MetaException, org.apache.thrift.TException
IMetaStoreClient
alter_table_with_environmentContext
in interface IMetaStoreClient
dbname
- database nametbl_name
- table namenew_tbl
- 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 exceptionpublic void alter_table(String catName, String dbName, String tblName, Table newTable, EnvironmentContext envContext) throws org.apache.thrift.TException
IMetaStoreClient
alter_table
in interface IMetaStoreClient
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 exceptionpublic void renamePartition(String dbname, String tableName, List<String> part_vals, Partition newPart) throws org.apache.thrift.TException
IMetaStoreClient
renamePartition
in interface IMetaStoreClient
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 serverpublic void renamePartition(String catName, String dbname, String tableName, List<String> part_vals, Partition newPart) throws org.apache.thrift.TException
IMetaStoreClient
renamePartition
in interface IMetaStoreClient
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 serverpublic String getTokenStrForm() throws IOException
getTokenStrForm
in interface IMetaStoreClient
IOException
public void close()
IMetaStoreClient
close
in interface AutoCloseable
close
in interface IMetaStoreClient
public void setMetaConf(String key, String value) throws org.apache.thrift.TException
IMetaStoreClient
setMetaConf
in interface IMetaStoreClient
org.apache.thrift.TException
public String getMetaConf(String key) throws org.apache.thrift.TException
IMetaStoreClient
getMetaConf
in interface IMetaStoreClient
org.apache.thrift.TException
public void createCatalog(Catalog catalog) throws org.apache.thrift.TException
IMetaStoreClient
createCatalog
in interface IMetaStoreClient
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.public void alterCatalog(String catalogName, Catalog newCatalog) throws org.apache.thrift.TException
IMetaStoreClient
alterCatalog
in interface IMetaStoreClient
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 exceptionpublic Catalog getCatalog(String catName) throws org.apache.thrift.TException
IMetaStoreClient
getCatalog
in interface IMetaStoreClient
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.public List<String> getCatalogs() throws org.apache.thrift.TException
IMetaStoreClient
getCatalogs
in interface IMetaStoreClient
MetaException
- something went wrong, usually in the database.org.apache.thrift.TException
- general thrift exception.public void dropCatalog(String catName) throws org.apache.thrift.TException
IMetaStoreClient
dropCatalog
in interface IMetaStoreClient
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.public Partition add_partition(Partition new_part) throws org.apache.thrift.TException
IMetaStoreClient
add_partition
in interface IMetaStoreClient
new_part
- InvalidObjectException
AlreadyExistsException
MetaException
org.apache.thrift.TException
ThriftHiveMetastore.Iface.add_partition(org.apache.hadoop.hive.metastore.api.Partition)
public Partition add_partition(Partition new_part, EnvironmentContext envContext) throws org.apache.thrift.TException
org.apache.thrift.TException
public int add_partitions(List<Partition> new_parts) throws org.apache.thrift.TException
IMetaStoreClient
add_partitions
in interface IMetaStoreClient
new_parts
- InvalidObjectException
AlreadyExistsException
MetaException
org.apache.thrift.TException
ThriftHiveMetastore.Iface.add_partitions(List)
public List<Partition> add_partitions(List<Partition> parts, boolean ifNotExists, boolean needResults) throws org.apache.thrift.TException
IMetaStoreClient
add_partitions
in interface IMetaStoreClient
parts
- The partitions to addifNotExists
- only add partitions if they don't existneedResults
- Whether the results are neededorg.apache.thrift.TException
public int add_partitions_pspec(PartitionSpecProxy partitionSpec) throws org.apache.thrift.TException
IMetaStoreClient
add_partitions_pspec
in interface IMetaStoreClient
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 errorpublic Partition appendPartition(String db_name, String table_name, List<String> part_vals) throws org.apache.thrift.TException
IMetaStoreClient
appendPartition
in interface IMetaStoreClient
db_name
- database nametable_name
- table namepart_vals
- partition valuesInvalidObjectException
- no such tableAlreadyExistsException
- a partition with these values already existsMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorpublic Partition appendPartition(String dbName, String tableName, String partName) throws org.apache.thrift.TException
IMetaStoreClient
appendPartition
in interface IMetaStoreClient
dbName
- database name.tableName
- table name.partName
- 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 errorpublic Partition appendPartition(String catName, String dbName, String tableName, String name) throws org.apache.thrift.TException
IMetaStoreClient
appendPartition
in interface IMetaStoreClient
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 errorpublic Partition appendPartition(String catName, String dbName, String tableName, List<String> partVals) throws org.apache.thrift.TException
IMetaStoreClient
appendPartition
in interface IMetaStoreClient
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 error@Deprecated public Partition appendPartition(String dbName, String tableName, List<String> partVals, EnvironmentContext ec) throws org.apache.thrift.TException
org.apache.thrift.TException
public Partition exchange_partition(Map<String,String> partitionSpecs, String sourceDb, String sourceTable, String destDb, String destinationTableName) throws org.apache.thrift.TException
exchange_partition
in interface IMetaStoreClient
partitionSpecs
- partitions specs of the parent partition to be exchangeddestDb
- the db of the destination tabledestinationTableName
- the destination table namesourceDb
- database of the source tablesourceTable
- name of the source 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 errorpublic Partition exchange_partition(Map<String,String> partitionSpecs, String sourceCat, String sourceDb, String sourceTable, String destCat, String destDb, String destTableName) throws org.apache.thrift.TException
IMetaStoreClient
exchange_partition
in interface IMetaStoreClient
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 errorpublic List<Partition> exchange_partitions(Map<String,String> partitionSpecs, String sourceDb, String sourceTable, String destDb, String destinationTableName) throws org.apache.thrift.TException
exchange_partitions
in interface IMetaStoreClient
partitionSpecs
- partitions specs of the parent partition to be exchangeddestDb
- the db of the destination tabledestinationTableName
- the destination table namesourceDb
- database of the source tablesourceTable
- name of the source 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 errorpublic List<Partition> exchange_partitions(Map<String,String> partitionSpecs, String sourceCat, String sourceDb, String sourceTable, String destCat, String destDb, String destTableName) throws org.apache.thrift.TException
IMetaStoreClient
exchange_partitions
in interface IMetaStoreClient
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 errorpublic void validatePartitionNameCharacters(List<String> partVals) throws org.apache.thrift.TException, MetaException
validatePartitionNameCharacters
in interface IMetaStoreClient
org.apache.thrift.TException
MetaException
public void createDatabase(Database db) throws AlreadyExistsException, InvalidObjectException, MetaException, org.apache.thrift.TException
createDatabase
in interface IMetaStoreClient
db
- AlreadyExistsException
InvalidObjectException
MetaException
org.apache.thrift.TException
ThriftHiveMetastore.Iface.create_database(Database)
public void createTable(Table tbl) throws AlreadyExistsException, InvalidObjectException, MetaException, NoSuchObjectException, org.apache.thrift.TException
createTable
in interface IMetaStoreClient
tbl
- MetaException
NoSuchObjectException
org.apache.thrift.TException
AlreadyExistsException
InvalidObjectException
ThriftHiveMetastore.Iface.create_table(org.apache.hadoop.hive.metastore.api.Table)
public void createTable(Table tbl, EnvironmentContext envContext) throws AlreadyExistsException, InvalidObjectException, MetaException, NoSuchObjectException, org.apache.thrift.TException
AlreadyExistsException
InvalidObjectException
MetaException
NoSuchObjectException
org.apache.thrift.TException
public void createTableWithConstraints(Table tbl, 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
createTableWithConstraints
in interface IMetaStoreClient
AlreadyExistsException
InvalidObjectException
MetaException
NoSuchObjectException
org.apache.thrift.TException
public void dropConstraint(String dbName, String tableName, String constraintName) throws org.apache.thrift.TException
IMetaStoreClient
dropConstraint
in interface IMetaStoreClient
dbName
- database nametableName
- table nameconstraintName
- name of the constraintMetaException
- RDBMS access errorNoSuchObjectException
- no such constraint existsorg.apache.thrift.TException
- thrift transport errorpublic void dropConstraint(String catName, String dbName, String tableName, String constraintName) throws org.apache.thrift.TException
IMetaStoreClient
dropConstraint
in interface IMetaStoreClient
catName
- catalog namedbName
- database nametableName
- table nameconstraintName
- name of the constraintMetaException
- RDBMS access errorNoSuchObjectException
- no such constraint existsorg.apache.thrift.TException
- thrift transport errorpublic void addPrimaryKey(List<SQLPrimaryKey> primaryKeyCols) throws org.apache.thrift.TException
IMetaStoreClient
addPrimaryKey
in interface IMetaStoreClient
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 errorpublic void addForeignKey(List<SQLForeignKey> foreignKeyCols) throws org.apache.thrift.TException
IMetaStoreClient
addForeignKey
in interface IMetaStoreClient
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 errorpublic void addUniqueConstraint(List<SQLUniqueConstraint> uniqueConstraintCols) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
IMetaStoreClient
addUniqueConstraint
in interface IMetaStoreClient
uniqueConstraintCols
- Unique constraint definitionNoSuchObjectException
- no such tableMetaException
- error reading or writing to the RDBMS or unique constraint already existsorg.apache.thrift.TException
- thrift transport errorpublic void addNotNullConstraint(List<SQLNotNullConstraint> notNullConstraintCols) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
IMetaStoreClient
addNotNullConstraint
in interface IMetaStoreClient
notNullConstraintCols
- Notnull constraint definitionNoSuchObjectException
- no such tableMetaException
- error reading or writing to the RDBMS or not null constraint already
existsorg.apache.thrift.TException
- thrift transport errorpublic void addDefaultConstraint(List<SQLDefaultConstraint> defaultConstraints) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
addDefaultConstraint
in interface IMetaStoreClient
NoSuchObjectException
MetaException
org.apache.thrift.TException
public void addCheckConstraint(List<SQLCheckConstraint> checkConstraints) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
addCheckConstraint
in interface IMetaStoreClient
NoSuchObjectException
MetaException
org.apache.thrift.TException
public boolean createType(Type type) throws AlreadyExistsException, InvalidObjectException, MetaException, org.apache.thrift.TException
type
- AlreadyExistsException
InvalidObjectException
MetaException
org.apache.thrift.TException
ThriftHiveMetastore.Iface.create_type(org.apache.hadoop.hive.metastore.api.Type)
public void dropDatabase(String name) throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException
IMetaStoreClient
dropDatabase
in interface IMetaStoreClient
name
- NoSuchObjectException
InvalidOperationException
MetaException
org.apache.thrift.TException
ThriftHiveMetastore.Iface.drop_database(java.lang.String, boolean, boolean)
public void dropDatabase(String name, boolean deleteData, boolean ignoreUnknownDb) throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException
IMetaStoreClient
dropDatabase
in interface IMetaStoreClient
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.public void dropDatabase(String name, boolean deleteData, boolean ignoreUnknownDb, boolean cascade) throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException
IMetaStoreClient
dropDatabase
in interface IMetaStoreClient
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.public void dropDatabase(String catalogName, String dbName, boolean deleteData, boolean ignoreUnknownDb, boolean cascade) throws NoSuchObjectException, InvalidOperationException, MetaException, org.apache.thrift.TException
IMetaStoreClient
dropDatabase
in interface IMetaStoreClient
catalogName
- 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.public boolean dropPartition(String dbName, String tableName, String partName, boolean deleteData) throws org.apache.thrift.TException
IMetaStoreClient
dropPartition
in interface IMetaStoreClient
dbName
- database name.tableName
- table name.partName
- 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 errorpublic boolean dropPartition(String catName, String db_name, String tbl_name, String name, boolean deleteData) throws org.apache.thrift.TException
IMetaStoreClient
dropPartition
in interface IMetaStoreClient
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 error@Deprecated public boolean dropPartition(String db_name, String tbl_name, List<String> part_vals, EnvironmentContext env_context) throws org.apache.thrift.TException
org.apache.thrift.TException
@Deprecated public boolean dropPartition(String dbName, String tableName, String partName, boolean dropData, EnvironmentContext ec) throws org.apache.thrift.TException
org.apache.thrift.TException
@Deprecated public boolean dropPartition(String dbName, String tableName, List<String> partVals) throws org.apache.thrift.TException
org.apache.thrift.TException
public boolean dropPartition(String db_name, String tbl_name, List<String> part_vals, boolean deleteData) throws org.apache.thrift.TException
IMetaStoreClient
dropPartition
in interface IMetaStoreClient
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 errorpublic boolean dropPartition(String catName, String db_name, String tbl_name, List<String> part_vals, boolean deleteData) throws org.apache.thrift.TException
IMetaStoreClient
dropPartition
in interface IMetaStoreClient
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 errorpublic boolean dropPartition(String db_name, String tbl_name, List<String> part_vals, PartitionDropOptions options) throws org.apache.thrift.TException
IMetaStoreClient
dropPartition
in interface IMetaStoreClient
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.public boolean dropPartition(String catName, String db_name, String tbl_name, List<String> part_vals, PartitionDropOptions options) throws org.apache.thrift.TException
IMetaStoreClient
dropPartition
in interface IMetaStoreClient
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.public List<Partition> dropPartitions(String dbName, String tblName, List<ObjectPair<Integer,byte[]>> partExprs, PartitionDropOptions options) throws org.apache.thrift.TException
IMetaStoreClient
dropPartitions
in interface IMetaStoreClient
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 failurepublic List<Partition> dropPartitions(String dbName, String tblName, List<ObjectPair<Integer,byte[]>> partExprs, boolean deleteData, boolean ifExists, boolean needResult) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
IMetaStoreClient
dropPartitions
in interface IMetaStoreClient
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).needResult
- 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.public List<Partition> dropPartitions(String dbName, String tblName, List<ObjectPair<Integer,byte[]>> partExprs, boolean deleteData, boolean ifExists) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
IMetaStoreClient
dropPartitions
in interface IMetaStoreClient
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.public List<Partition> dropPartitions(String catName, String dbName, String tblName, List<ObjectPair<Integer,byte[]>> partExprs, PartitionDropOptions options) throws org.apache.thrift.TException
IMetaStoreClient
dropPartitions
in interface IMetaStoreClient
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 failurepublic void dropTable(String dbname, String name, boolean deleteData, boolean ignoreUnknownTab) throws MetaException, org.apache.thrift.TException, NoSuchObjectException, UnsupportedOperationException
IMetaStoreClient
dropTable
in interface IMetaStoreClient
dbname
- The database for this tablename
- 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 occurredUnsupportedOperationException
public void dropTable(String dbname, String name, boolean deleteData, boolean ignoreUnknownTab, boolean ifPurge) throws org.apache.thrift.TException
IMetaStoreClient
dropTable
in interface IMetaStoreClient
dbname
- The database for this tablename
- 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 occurredpublic void dropTable(String dbname, String name) throws org.apache.thrift.TException
IMetaStoreClient
dropTable
in interface IMetaStoreClient
dbname
- The database for this tablename
- The table to dropMetaException
- Could not drop table properly.NoSuchObjectException
- The table wasn't found.org.apache.thrift.TException
- A thrift communication error occurredpublic void dropTable(String catName, String dbName, String tableName, boolean deleteData, boolean ignoreUnknownTable, boolean ifPurge) throws org.apache.thrift.TException
IMetaStoreClient
dropTable
in interface IMetaStoreClient
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.public void dropTable(String catName, String dbname, String name, boolean deleteData, boolean ignoreUnknownTab, EnvironmentContext envContext) throws MetaException, org.apache.thrift.TException, NoSuchObjectException, UnsupportedOperationException
catName
- catalog namedbname
- database namename
- table namedeleteData
- delete the underlying data or just delete the table in metadataignoreUnknownTab
- don't throw if the requested table doesn't existenvContext
- for communicating with thriftMetaException
- could not drop table properlyNoSuchObjectException
- the table wasn't foundorg.apache.thrift.TException
- a thrift communication error occurredUnsupportedOperationException
- dropping an index table is not allowedThriftHiveMetastore.Iface.drop_table(java.lang.String,
java.lang.String, boolean)
public void truncateTable(String dbName, String tableName, List<String> partNames) throws org.apache.thrift.TException
IMetaStoreClient
truncateTable
in interface IMetaStoreClient
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 exceptionpublic void truncateTable(String catName, String dbName, String tableName, List<String> partNames) throws org.apache.thrift.TException
IMetaStoreClient
truncateTable
in interface IMetaStoreClient
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 exceptionpublic CmRecycleResponse recycleDirToCmPath(CmRecycleRequest request) throws MetaException, org.apache.thrift.TException
recycleDirToCmPath
in interface IMetaStoreClient
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
public boolean dropType(String type) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
type
- MetaException
org.apache.thrift.TException
NoSuchObjectException
ThriftHiveMetastore.Iface.drop_type(java.lang.String)
public Map<String,Type> getTypeAll(String name) throws MetaException, org.apache.thrift.TException
name
- MetaException
org.apache.thrift.TException
ThriftHiveMetastore.Iface.get_type_all(java.lang.String)
public List<String> getDatabases(String databasePattern) throws org.apache.thrift.TException
IMetaStoreClient
getDatabases
in interface IMetaStoreClient
databasePattern
- pattern for the database name to patchMetaException
- error accessing RDBMS.org.apache.thrift.TException
- thrift transport errorpublic List<String> getDatabases(String catName, String databasePattern) throws org.apache.thrift.TException
IMetaStoreClient
getDatabases
in interface IMetaStoreClient
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 errorpublic List<String> getAllDatabases() throws org.apache.thrift.TException
IMetaStoreClient
getAllDatabases
in interface IMetaStoreClient
MetaException
- error accessing RDBMS.org.apache.thrift.TException
- thrift transport errorpublic List<String> getAllDatabases(String catName) throws org.apache.thrift.TException
IMetaStoreClient
getAllDatabases
in interface IMetaStoreClient
catName
- catalog name. Can be null, in which case the default catalog is assumed.MetaException
- error accessing RDBMS.org.apache.thrift.TException
- thrift transport errorpublic List<Partition> listPartitions(String db_name, String tbl_name, short max_parts) throws org.apache.thrift.TException
IMetaStoreClient
listPartitions
in interface IMetaStoreClient
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 errorpublic List<Partition> listPartitions(String catName, String db_name, String tbl_name, int max_parts) throws org.apache.thrift.TException
IMetaStoreClient
listPartitions
in interface IMetaStoreClient
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 errorpublic PartitionSpecProxy listPartitionSpecs(String dbName, String tableName, int maxParts) throws org.apache.thrift.TException
IMetaStoreClient
listPartitionSpecs
in interface IMetaStoreClient
dbName
- database name.tableName
- table name.maxParts
- maximum number of partitions to return, or -1 for allorg.apache.thrift.TException
- thrift transport errorpublic PartitionSpecProxy listPartitionSpecs(String catName, String dbName, String tableName, int maxParts) throws org.apache.thrift.TException
IMetaStoreClient
listPartitionSpecs
in interface IMetaStoreClient
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 errorpublic List<Partition> listPartitions(String db_name, String tbl_name, List<String> part_vals, short max_parts) throws org.apache.thrift.TException
IMetaStoreClient
listPartitions
in interface IMetaStoreClient
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.public List<Partition> listPartitions(String catName, String db_name, String tbl_name, List<String> part_vals, int max_parts) throws org.apache.thrift.TException
IMetaStoreClient
listPartitions
in interface IMetaStoreClient
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.public List<Partition> listPartitionsWithAuthInfo(String db_name, String tbl_name, short max_parts, String user_name, List<String> group_names) throws org.apache.thrift.TException
IMetaStoreClient
listPartitionsWithAuthInfo
in interface IMetaStoreClient
db_name
- database nametbl_name
- table namemax_parts
- maximum number of partitions to fetch, or -1 for alluser_name
- user to fetch privileges forgroup_names
- groups to fetch privileges forNoSuchObjectException
- no partitions matching the criteria were foundMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorpublic List<Partition> listPartitionsWithAuthInfo(String catName, String dbName, String tableName, int maxParts, String userName, List<String> groupNames) throws org.apache.thrift.TException
IMetaStoreClient
listPartitionsWithAuthInfo
in interface IMetaStoreClient
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 errorpublic List<Partition> listPartitionsWithAuthInfo(String db_name, String tbl_name, List<String> part_vals, short max_parts, String user_name, List<String> group_names) throws org.apache.thrift.TException
IMetaStoreClient
listPartitionsWithAuthInfo
in interface IMetaStoreClient
db_name
- database nametbl_name
- table namepart_vals
- partition values, can be partialmax_parts
- maximum number of partitions to fetch, or -1 for alluser_name
- user to fetch privilege information forgroup_names
- group to fetch privilege information forNoSuchObjectException
- no partitions matching the criteria were foundMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorpublic List<Partition> listPartitionsWithAuthInfo(String catName, String dbName, String tableName, List<String> partialPvals, int maxParts, String userName, List<String> groupNames) throws org.apache.thrift.TException
IMetaStoreClient
listPartitionsWithAuthInfo
in interface IMetaStoreClient
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 errorpublic List<Partition> listPartitionsByFilter(String db_name, String tbl_name, String filter, short max_parts) throws org.apache.thrift.TException
IMetaStoreClient
listPartitionsByFilter
in interface IMetaStoreClient
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 errorpublic List<Partition> listPartitionsByFilter(String catName, String db_name, String tbl_name, String filter, int max_parts) throws org.apache.thrift.TException
IMetaStoreClient
listPartitionsByFilter
in interface IMetaStoreClient
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 errorpublic PartitionSpecProxy listPartitionSpecsByFilter(String db_name, String tbl_name, String filter, int max_parts) throws org.apache.thrift.TException
IMetaStoreClient
listPartitionSpecsByFilter
in interface IMetaStoreClient
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 errorpublic PartitionSpecProxy listPartitionSpecsByFilter(String catName, String db_name, String tbl_name, String filter, int max_parts) throws org.apache.thrift.TException
IMetaStoreClient
listPartitionSpecsByFilter
in interface IMetaStoreClient
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 errorpublic boolean listPartitionsByExpr(String db_name, String tbl_name, byte[] expr, String default_partition_name, short max_parts, List<Partition> result) throws org.apache.thrift.TException
IMetaStoreClient
listPartitionsByExpr
in interface IMetaStoreClient
db_name
- the database nametbl_name
- the table nameexpr
- expression, serialized from ExprNodeDescdefault_partition_name
- Default partition name from configuration. If blank, the
metastore server-side configuration is used.max_parts
- the maximum number of partitions to return,
all partitions are returned if -1 is passedresult
- the resulting list of partitionsorg.apache.thrift.TException
- thrift transport error or error executing the filter.public 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
IMetaStoreClient
listPartitionsByExpr
in interface IMetaStoreClient
catName
- catalog namedb_name
- the database nametbl_name
- the table nameexpr
- expression, serialized from ExprNodeDescdefault_partition_name
- Default partition name from configuration. If blank, the
metastore server-side configuration is used.max_parts
- the maximum number of partitions to return,
all partitions are returned if -1 is passedresult
- the resulting list of partitionsorg.apache.thrift.TException
- thrift transport error or error executing the filter.public Database getDatabase(String name) throws org.apache.thrift.TException
IMetaStoreClient
getDatabase
in interface IMetaStoreClient
name
- name of the database to fetchNoSuchObjectException
- The database does not existMetaException
- Could not fetch the databaseorg.apache.thrift.TException
- A thrift communication error occurredpublic Database getDatabase(String catalogName, String databaseName) throws org.apache.thrift.TException
IMetaStoreClient
getDatabase
in interface IMetaStoreClient
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 errorpublic Partition getPartition(String db_name, String tbl_name, List<String> part_vals) throws org.apache.thrift.TException
IMetaStoreClient
getPartition
in interface IMetaStoreClient
db_name
- database nametbl_name
- table namepart_vals
- 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 errorpublic Partition getPartition(String catName, String dbName, String tblName, List<String> partVals) throws org.apache.thrift.TException
IMetaStoreClient
getPartition
in interface IMetaStoreClient
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 errorpublic List<Partition> getPartitionsByNames(String db_name, String tbl_name, List<String> part_names) throws org.apache.thrift.TException
IMetaStoreClient
getPartitionsByNames
in interface IMetaStoreClient
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 errorpublic List<Partition> getPartitionsByNames(String catName, String db_name, String tbl_name, List<String> part_names) throws org.apache.thrift.TException
IMetaStoreClient
getPartitionsByNames
in interface IMetaStoreClient
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 errorpublic PartitionValuesResponse listPartitionValues(PartitionValuesRequest request) throws MetaException, org.apache.thrift.TException, NoSuchObjectException
IMetaStoreClient
listPartitionValues
in interface IMetaStoreClient
request
- requestMetaException
- error accessing RDBMSorg.apache.thrift.TException
- thrift transport errorNoSuchObjectException
- no such tablepublic Partition getPartitionWithAuthInfo(String db_name, String tbl_name, List<String> part_vals, String user_name, List<String> group_names) throws org.apache.thrift.TException
IMetaStoreClient
getPartitionWithAuthInfo
in interface IMetaStoreClient
db_name
- database nametbl_name
- table namepart_vals
- partition values, must be in the same order as the tables partition keysuser_name
- name of the calling usergroup_names
- groups the callMetaException
- error accessing the RDBMSUnknownTableException
- no such tableNoSuchObjectException
- no such partitionorg.apache.thrift.TException
- thrift transport errorpublic Partition getPartitionWithAuthInfo(String catName, String dbName, String tableName, List<String> pvals, String userName, List<String> groupNames) throws org.apache.thrift.TException
IMetaStoreClient
getPartitionWithAuthInfo
in interface IMetaStoreClient
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 errorpublic Table getTable(String dbname, String name) throws org.apache.thrift.TException
IMetaStoreClient
getTable
in interface IMetaStoreClient
dbname
- The database the table is located in.name
- 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.public Table getTable(String catName, String dbName, String tableName) throws org.apache.thrift.TException
IMetaStoreClient
getTable
in interface IMetaStoreClient
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.public List<Table> getTableObjectsByName(String dbName, List<String> tableNames) throws org.apache.thrift.TException
IMetaStoreClient
getTableObjectsByName
in interface IMetaStoreClient
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 errorspublic List<Table> getTableObjectsByName(String catName, String dbName, List<String> tableNames) throws org.apache.thrift.TException
IMetaStoreClient
getTableObjectsByName
in interface IMetaStoreClient
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 errorspublic Materialization getMaterializationInvalidationInfo(CreationMetadata cm, String validTxnList) throws MetaException, InvalidOperationException, UnknownDBException, org.apache.thrift.TException
IMetaStoreClient
getMaterializationInvalidationInfo
in interface IMetaStoreClient
MetaException
InvalidOperationException
UnknownDBException
org.apache.thrift.TException
public void updateCreationMetadata(String dbName, String tableName, CreationMetadata cm) throws MetaException, InvalidOperationException, UnknownDBException, org.apache.thrift.TException
IMetaStoreClient
updateCreationMetadata
in interface IMetaStoreClient
MetaException
InvalidOperationException
UnknownDBException
org.apache.thrift.TException
public void updateCreationMetadata(String catName, String dbName, String tableName, CreationMetadata cm) throws MetaException, org.apache.thrift.TException
IMetaStoreClient
updateCreationMetadata
in interface IMetaStoreClient
MetaException
org.apache.thrift.TException
public List<String> listTableNamesByFilter(String dbName, String filter, short maxTables) throws org.apache.thrift.TException
listTableNamesByFilter
in interface IMetaStoreClient
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 errorpublic List<String> listTableNamesByFilter(String catName, String dbName, String filter, int maxTables) throws org.apache.thrift.TException
IMetaStoreClient
listTableNamesByFilter
in interface IMetaStoreClient
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 errorpublic Type getType(String name) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
name
- MetaException
org.apache.thrift.TException
NoSuchObjectException
ThriftHiveMetastore.Iface.get_type(java.lang.String)
public List<String> getTables(String dbname, String tablePattern) throws MetaException
IMetaStoreClient
getTables
in interface IMetaStoreClient
dbname
- database name.tablePattern
- pattern for table name to conform toMetaException
- error fetching information from the RDBMSpublic List<String> getTables(String catName, String dbName, String tablePattern) throws org.apache.thrift.TException
IMetaStoreClient
getTables
in interface IMetaStoreClient
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.public List<String> getTables(String dbname, String tablePattern, TableType tableType) throws MetaException
IMetaStoreClient
getTables
in interface IMetaStoreClient
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 RDBMSpublic List<String> getTables(String catName, String dbName, String tablePattern, TableType tableType) throws org.apache.thrift.TException
IMetaStoreClient
getTables
in interface IMetaStoreClient
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.public List<String> getMaterializedViewsForRewriting(String dbName) throws org.apache.thrift.TException
IMetaStoreClient
getMaterializedViewsForRewriting
in interface IMetaStoreClient
dbName
- Name of the database to fetch materialized views from.MetaException
- error fetching from the RDBMSorg.apache.thrift.TException
- thrift transport errorUnknownDBException
- no such databasepublic List<String> getMaterializedViewsForRewriting(String catName, String dbname) throws MetaException
IMetaStoreClient
getMaterializedViewsForRewriting
in interface IMetaStoreClient
catName
- catalog name.dbname
- Name of the database to fetch materialized views from.MetaException
- error fetching from the RDBMSpublic List<TableMeta> getTableMeta(String dbPatterns, String tablePatterns, List<String> tableTypes) throws MetaException
IMetaStoreClient
getTableMeta
in interface IMetaStoreClient
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 RDBMSpublic List<TableMeta> getTableMeta(String catName, String dbPatterns, String tablePatterns, List<String> tableTypes) throws org.apache.thrift.TException
IMetaStoreClient
getTableMeta
in interface IMetaStoreClient
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.public List<String> getAllTables(String dbname) throws MetaException
IMetaStoreClient
getAllTables
in interface IMetaStoreClient
dbname
- database nameMetaException
- something went wrong with the fetch from the RDBMSpublic List<String> getAllTables(String catName, String dbName) throws org.apache.thrift.TException
IMetaStoreClient
getAllTables
in interface IMetaStoreClient
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.public boolean tableExists(String databaseName, String tableName) throws org.apache.thrift.TException
IMetaStoreClient
tableExists
in interface IMetaStoreClient
databaseName
- database nametableName
- table nameMetaException
- error fetching form the RDBMSorg.apache.thrift.TException
- thrift transport errorUnknownDBException
- the indicated database does not exist.public boolean tableExists(String catName, String dbName, String tableName) throws org.apache.thrift.TException
IMetaStoreClient
tableExists
in interface IMetaStoreClient
catName
- catalog namedbName
- database nametableName
- table nameMetaException
- error fetching form the RDBMSorg.apache.thrift.TException
- thrift transport errorUnknownDBException
- the indicated database does not exist.public List<String> listPartitionNames(String dbName, String tblName, short max) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
IMetaStoreClient
listPartitionNames
in interface IMetaStoreClient
dbName
- database name.tblName
- table name.max
- 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 errorpublic List<String> listPartitionNames(String catName, String dbName, String tableName, int maxParts) throws org.apache.thrift.TException
IMetaStoreClient
listPartitionNames
in interface IMetaStoreClient
catName
- catalog name.dbName
- database name.tableName
- table name.maxParts
- 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 errorpublic List<String> listPartitionNames(String db_name, String tbl_name, List<String> part_vals, short max_parts) throws org.apache.thrift.TException
IMetaStoreClient
listPartitionNames
in interface IMetaStoreClient
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.public List<String> listPartitionNames(String catName, String db_name, String tbl_name, List<String> part_vals, int max_parts) throws org.apache.thrift.TException
IMetaStoreClient
listPartitionNames
in interface IMetaStoreClient
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.public int getNumPartitionsByFilter(String db_name, String tbl_name, String filter) throws org.apache.thrift.TException
IMetaStoreClient
getNumPartitionsByFilter
in interface IMetaStoreClient
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.MetaException
- error accessing RDBMS or processing the filterNoSuchObjectException
- no such tableorg.apache.thrift.TException
- thrift transport errorpublic int getNumPartitionsByFilter(String catName, String dbName, String tableName, String filter) throws org.apache.thrift.TException
IMetaStoreClient
getNumPartitionsByFilter
in interface IMetaStoreClient
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 errorpublic void alter_partition(String dbName, String tblName, Partition newPart) throws InvalidOperationException, MetaException, org.apache.thrift.TException
IMetaStoreClient
alter_partition
in interface IMetaStoreClient
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 serverpublic void alter_partition(String dbName, String tblName, Partition newPart, EnvironmentContext environmentContext) throws InvalidOperationException, MetaException, org.apache.thrift.TException
IMetaStoreClient
alter_partition
in interface IMetaStoreClient
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 serverpublic void alter_partition(String catName, String dbName, String tblName, Partition newPart, EnvironmentContext environmentContext) throws org.apache.thrift.TException
IMetaStoreClient
alter_partition
in interface IMetaStoreClient
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 serverpublic void alter_partitions(String dbName, String tblName, List<Partition> newParts) throws org.apache.thrift.TException
IMetaStoreClient
alter_partitions
in interface IMetaStoreClient
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 serverpublic void alter_partitions(String dbName, String tblName, List<Partition> newParts, EnvironmentContext environmentContext) throws org.apache.thrift.TException
IMetaStoreClient
alter_partitions
in interface IMetaStoreClient
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 serverpublic void alter_partitions(String catName, String dbName, String tblName, List<Partition> newParts, EnvironmentContext environmentContext) throws org.apache.thrift.TException
IMetaStoreClient
alter_partitions
in interface IMetaStoreClient
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 serverpublic void alterDatabase(String dbName, Database db) throws org.apache.thrift.TException
IMetaStoreClient
alterDatabase
in interface IMetaStoreClient
dbName
- 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.public void alterDatabase(String catName, String dbName, Database newDb) throws org.apache.thrift.TException
IMetaStoreClient
alterDatabase
in interface IMetaStoreClient
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.public List<FieldSchema> getFields(String db, String tableName) throws org.apache.thrift.TException
IMetaStoreClient
getFields
in interface IMetaStoreClient
db
- database nametableName
- table nameUnknownTableException
- no such tableUnknownDBException
- no such databaseMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorpublic List<FieldSchema> getFields(String catName, String db, String tableName) throws org.apache.thrift.TException
IMetaStoreClient
getFields
in interface IMetaStoreClient
catName
- catalog namedb
- database nametableName
- table nameUnknownTableException
- no such tableUnknownDBException
- no such databaseMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorpublic List<SQLPrimaryKey> getPrimaryKeys(PrimaryKeysRequest req) throws org.apache.thrift.TException
IMetaStoreClient
getPrimaryKeys
in interface IMetaStoreClient
req
- Request infoMetaException
- error reading the RDBMSNoSuchObjectException
- no primary key exists on this table, or maybe no such tableorg.apache.thrift.TException
- thrift transport errorpublic List<SQLForeignKey> getForeignKeys(ForeignKeysRequest req) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
IMetaStoreClient
getForeignKeys
in interface IMetaStoreClient
req
- Request infoMetaException
- error reading the RDBMSNoSuchObjectException
- no foreign key exists on this table, or maybe no such tableorg.apache.thrift.TException
- thrift transport errorpublic List<SQLUniqueConstraint> getUniqueConstraints(UniqueConstraintsRequest req) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
IMetaStoreClient
getUniqueConstraints
in interface IMetaStoreClient
req
- Request infoMetaException
- error reading the RDBMSNoSuchObjectException
- no unique constraint on this table, or maybe no such tableorg.apache.thrift.TException
- thrift transport errorpublic List<SQLNotNullConstraint> getNotNullConstraints(NotNullConstraintsRequest req) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
IMetaStoreClient
getNotNullConstraints
in interface IMetaStoreClient
req
- Request infoMetaException
- error reading the RDBMSNoSuchObjectException
- no not null constraint on this table, or maybe no such tableorg.apache.thrift.TException
- thrift transport errorpublic List<SQLDefaultConstraint> getDefaultConstraints(DefaultConstraintsRequest req) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
getDefaultConstraints
in interface IMetaStoreClient
MetaException
NoSuchObjectException
org.apache.thrift.TException
public List<SQLCheckConstraint> getCheckConstraints(CheckConstraintsRequest req) throws MetaException, NoSuchObjectException, org.apache.thrift.TException
getCheckConstraints
in interface IMetaStoreClient
MetaException
NoSuchObjectException
org.apache.thrift.TException
public boolean updateTableColumnStatistics(ColumnStatistics statsObj) throws org.apache.thrift.TException
updateTableColumnStatistics
in interface IMetaStoreClient
NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
InvalidInputException
public boolean updatePartitionColumnStatistics(ColumnStatistics statsObj) throws org.apache.thrift.TException
IMetaStoreClient
updatePartitionColumnStatistics
in interface IMetaStoreClient
NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
InvalidInputException
public boolean setPartitionColumnStatistics(SetPartitionsStatsRequest request) throws org.apache.thrift.TException
IMetaStoreClient
setPartitionColumnStatistics
in interface IMetaStoreClient
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)public void flushCache()
IMetaStoreClient
flushCache
in interface IMetaStoreClient
public List<ColumnStatisticsObj> getTableColumnStatistics(String dbName, String tableName, List<String> colNames) throws org.apache.thrift.TException
IMetaStoreClient
IMetaStoreClient.getPartitionColumnStatistics(String, String, List, List)
.getTableColumnStatistics
in interface IMetaStoreClient
dbName
- database nametableName
- table namecolNames
- list of column namesNoSuchObjectException
- no such tableMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorpublic List<ColumnStatisticsObj> getTableColumnStatistics(String catName, String dbName, String tableName, List<String> colNames) throws org.apache.thrift.TException
IMetaStoreClient
IMetaStoreClient.getPartitionColumnStatistics(String, String, String, List, List)
.getTableColumnStatistics
in interface IMetaStoreClient
catName
- catalog namedbName
- database nametableName
- table namecolNames
- list of column namesNoSuchObjectException
- no such tableMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorpublic Map<String,List<ColumnStatisticsObj>> getPartitionColumnStatistics(String dbName, String tableName, List<String> partNames, List<String> colNames) throws org.apache.thrift.TException
IMetaStoreClient
getPartitionColumnStatistics
in interface IMetaStoreClient
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 errorpublic Map<String,List<ColumnStatisticsObj>> getPartitionColumnStatistics(String catName, String dbName, String tableName, List<String> partNames, List<String> colNames) throws org.apache.thrift.TException
IMetaStoreClient
getPartitionColumnStatistics
in interface IMetaStoreClient
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 errorpublic boolean deletePartitionColumnStatistics(String dbName, String tableName, String partName, String colName) throws org.apache.thrift.TException
IMetaStoreClient
deletePartitionColumnStatistics
in interface IMetaStoreClient
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.public boolean deletePartitionColumnStatistics(String catName, String dbName, String tableName, String partName, String colName) throws org.apache.thrift.TException
IMetaStoreClient
deletePartitionColumnStatistics
in interface IMetaStoreClient
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.public boolean deleteTableColumnStatistics(String dbName, String tableName, String colName) throws org.apache.thrift.TException
IMetaStoreClient
deleteTableColumnStatistics
in interface IMetaStoreClient
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.public boolean deleteTableColumnStatistics(String catName, String dbName, String tableName, String colName) throws org.apache.thrift.TException
IMetaStoreClient
deleteTableColumnStatistics
in interface IMetaStoreClient
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.public List<FieldSchema> getSchema(String db, String tableName) throws org.apache.thrift.TException
IMetaStoreClient
getSchema
in interface IMetaStoreClient
db
- database nametableName
- table nameUnknownTableException
- no such tableUnknownDBException
- no such databaseMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorpublic List<FieldSchema> getSchema(String catName, String db, String tableName) throws org.apache.thrift.TException
IMetaStoreClient
getSchema
in interface IMetaStoreClient
catName
- catalog namedb
- database nametableName
- table nameUnknownTableException
- no such tableUnknownDBException
- no such databaseMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorpublic String getConfigValue(String name, String defaultValue) throws org.apache.thrift.TException, ConfigValSecurityException
getConfigValue
in interface IMetaStoreClient
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
public Partition getPartition(String db, String tableName, String partName) throws org.apache.thrift.TException
IMetaStoreClient
getPartition
in interface IMetaStoreClient
db
- database name.tableName
- table name.partName
- - 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 errorpublic Partition getPartition(String catName, String dbName, String tblName, String name) throws org.apache.thrift.TException
IMetaStoreClient
getPartition
in interface IMetaStoreClient
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 errorpublic Partition appendPartitionByName(String dbName, String tableName, String partName) throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException
InvalidObjectException
AlreadyExistsException
MetaException
org.apache.thrift.TException
public Partition appendPartitionByName(String dbName, String tableName, String partName, EnvironmentContext envContext) throws InvalidObjectException, AlreadyExistsException, MetaException, org.apache.thrift.TException
InvalidObjectException
AlreadyExistsException
MetaException
org.apache.thrift.TException
public boolean dropPartitionByName(String dbName, String tableName, String partName, boolean deleteData) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
NoSuchObjectException
MetaException
org.apache.thrift.TException
public boolean dropPartitionByName(String dbName, String tableName, String partName, boolean deleteData, EnvironmentContext envContext) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
NoSuchObjectException
MetaException
org.apache.thrift.TException
public List<String> partitionNameToVals(String name) throws MetaException, org.apache.thrift.TException
partitionNameToVals
in interface IMetaStoreClient
name
- the partition name e.g. ("ds=2010-03-03/hr=12")MetaException
org.apache.thrift.TException
public Map<String,String> partitionNameToSpec(String name) throws MetaException, org.apache.thrift.TException
partitionNameToSpec
in interface IMetaStoreClient
name
- the partition name e.g. ("ds=2010-03-03/hr=12")MetaException
org.apache.thrift.TException
protected PrincipalPrivilegeSet deepCopy(PrincipalPrivilegeSet pps)
protected List<FieldSchema> deepCopyFieldSchemas(List<FieldSchema> schemas)
public boolean grant_role(String roleName, String userName, PrincipalType principalType, String grantor, PrincipalType grantorType, boolean grantOption) throws MetaException, org.apache.thrift.TException
grant_role
in interface IMetaStoreClient
MetaException
org.apache.thrift.TException
public boolean create_role(Role role) throws MetaException, org.apache.thrift.TException
create_role
in interface IMetaStoreClient
role
- role objectMetaException
org.apache.thrift.TException
public boolean drop_role(String roleName) throws MetaException, org.apache.thrift.TException
drop_role
in interface IMetaStoreClient
roleName
- role nameMetaException
org.apache.thrift.TException
public List<Role> list_roles(String principalName, PrincipalType principalType) throws MetaException, org.apache.thrift.TException
list_roles
in interface IMetaStoreClient
MetaException
org.apache.thrift.TException
public List<String> listRoleNames() throws MetaException, org.apache.thrift.TException
IMetaStoreClient
listRoleNames
in interface IMetaStoreClient
MetaException
org.apache.thrift.TException
public GetPrincipalsInRoleResponse get_principals_in_role(GetPrincipalsInRoleRequest req) throws MetaException, org.apache.thrift.TException
IMetaStoreClient
get_principals_in_role
in interface IMetaStoreClient
MetaException
org.apache.thrift.TException
public GetRoleGrantsForPrincipalResponse get_role_grants_for_principal(GetRoleGrantsForPrincipalRequest getRolePrincReq) throws MetaException, org.apache.thrift.TException
IMetaStoreClient
get_role_grants_for_principal
in interface IMetaStoreClient
MetaException
org.apache.thrift.TException
public boolean grant_privileges(PrivilegeBag privileges) throws MetaException, org.apache.thrift.TException
grant_privileges
in interface IMetaStoreClient
MetaException
org.apache.thrift.TException
public boolean revoke_role(String roleName, String userName, PrincipalType principalType, boolean grantOption) throws MetaException, org.apache.thrift.TException
revoke_role
in interface IMetaStoreClient
roleName
- role nameuserName
- user nameMetaException
org.apache.thrift.TException
public boolean revoke_privileges(PrivilegeBag privileges, boolean grantOption) throws MetaException, org.apache.thrift.TException
revoke_privileges
in interface IMetaStoreClient
MetaException
org.apache.thrift.TException
public boolean refresh_privileges(HiveObjectRef objToRefresh, String authorizer, PrivilegeBag grantPrivileges) throws MetaException, org.apache.thrift.TException
refresh_privileges
in interface IMetaStoreClient
MetaException
org.apache.thrift.TException
public PrincipalPrivilegeSet get_privilege_set(HiveObjectRef hiveObject, String userName, List<String> groupNames) throws MetaException, org.apache.thrift.TException
IMetaStoreClient
get_privilege_set
in interface IMetaStoreClient
MetaException
org.apache.thrift.TException
public List<HiveObjectPrivilege> list_privileges(String principalName, PrincipalType principalType, HiveObjectRef hiveObject) throws MetaException, org.apache.thrift.TException
IMetaStoreClient
list_privileges
in interface IMetaStoreClient
MetaException
org.apache.thrift.TException
public String getDelegationToken(String renewerKerberosPrincipalName) throws MetaException, org.apache.thrift.TException, IOException
MetaException
org.apache.thrift.TException
IOException
public String getDelegationToken(String owner, String renewerKerberosPrincipalName) throws MetaException, org.apache.thrift.TException
IMetaStoreClient
getDelegationToken
in interface IMetaStoreClient
owner
- the intended owner for the tokenMetaException
org.apache.thrift.TException
public long renewDelegationToken(String tokenStrForm) throws MetaException, org.apache.thrift.TException
renewDelegationToken
in interface IMetaStoreClient
MetaException
org.apache.thrift.TException
public void cancelDelegationToken(String tokenStrForm) throws MetaException, org.apache.thrift.TException
cancelDelegationToken
in interface IMetaStoreClient
MetaException
org.apache.thrift.TException
public boolean addToken(String tokenIdentifier, String delegationToken) throws org.apache.thrift.TException
addToken
in interface IMetaStoreClient
org.apache.thrift.TException
public boolean removeToken(String tokenIdentifier) throws org.apache.thrift.TException
removeToken
in interface IMetaStoreClient
org.apache.thrift.TException
public String getToken(String tokenIdentifier) throws org.apache.thrift.TException
getToken
in interface IMetaStoreClient
org.apache.thrift.TException
public List<String> getAllTokenIdentifiers() throws org.apache.thrift.TException
getAllTokenIdentifiers
in interface IMetaStoreClient
org.apache.thrift.TException
public int addMasterKey(String key) throws MetaException, org.apache.thrift.TException
addMasterKey
in interface IMetaStoreClient
MetaException
org.apache.thrift.TException
public void updateMasterKey(Integer seqNo, String key) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
updateMasterKey
in interface IMetaStoreClient
NoSuchObjectException
MetaException
org.apache.thrift.TException
public boolean removeMasterKey(Integer keySeq) throws org.apache.thrift.TException
removeMasterKey
in interface IMetaStoreClient
org.apache.thrift.TException
public String[] getMasterKeys() throws org.apache.thrift.TException
getMasterKeys
in interface IMetaStoreClient
org.apache.thrift.TException
public org.apache.hadoop.hive.common.ValidTxnList getValidTxns() throws org.apache.thrift.TException
IMetaStoreClient
getValidTxns
in interface IMetaStoreClient
org.apache.thrift.TException
public org.apache.hadoop.hive.common.ValidTxnList getValidTxns(long currentTxn) throws org.apache.thrift.TException
IMetaStoreClient
getValidTxns
in interface IMetaStoreClient
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
public org.apache.hadoop.hive.common.ValidWriteIdList getValidWriteIds(String fullTableName) throws org.apache.thrift.TException
IMetaStoreClient
getValidWriteIds
in interface IMetaStoreClient
fullTableName
- full table name of format <db_name>.<table_name>org.apache.thrift.TException
public List<TableValidWriteIds> getValidWriteIds(List<String> tablesList, String validTxnList) throws org.apache.thrift.TException
IMetaStoreClient
getValidWriteIds
in interface IMetaStoreClient
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
public long openTxn(String user) throws org.apache.thrift.TException
IMetaStoreClient
openTxn
in interface IMetaStoreClient
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
public List<Long> replOpenTxn(String replPolicy, List<Long> srcTxnIds, String user) throws org.apache.thrift.TException
IMetaStoreClient
replOpenTxn
in interface IMetaStoreClient
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
public OpenTxnsResponse openTxns(String user, int numTxns) throws org.apache.thrift.TException
IMetaStoreClient
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.
openTxns
in interface IMetaStoreClient
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
public void rollbackTxn(long txnid) throws NoSuchTxnException, org.apache.thrift.TException
IMetaStoreClient
rollbackTxn
in interface IMetaStoreClient
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
public void replRollbackTxn(long srcTxnId, String replPolicy) throws NoSuchTxnException, org.apache.thrift.TException
IMetaStoreClient
replRollbackTxn
in interface IMetaStoreClient
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
public void commitTxn(long txnid) throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
IMetaStoreClient
commitTxn
in interface IMetaStoreClient
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
public void replCommitTxn(long srcTxnId, String replPolicy) throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
IMetaStoreClient
replCommitTxn
in interface IMetaStoreClient
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
public GetOpenTxnsInfoResponse showTxns() throws org.apache.thrift.TException
IMetaStoreClient
IMetaStoreClient.getValidTxns()
.showTxns
in interface IMetaStoreClient
org.apache.thrift.TException
public void abortTxns(List<Long> txnids) throws NoSuchTxnException, org.apache.thrift.TException
IMetaStoreClient
abortTxns
in interface IMetaStoreClient
org.apache.thrift.TException
NoSuchTxnException
public void replTableWriteIdState(String validWriteIdList, String dbName, String tableName, List<String> partNames) throws org.apache.thrift.TException
IMetaStoreClient
replTableWriteIdState
in interface IMetaStoreClient
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 statepublic long allocateTableWriteId(long txnId, String dbName, String tableName) throws org.apache.thrift.TException
IMetaStoreClient
allocateTableWriteId
in interface IMetaStoreClient
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
public List<TxnToWriteId> allocateTableWriteIdsBatch(List<Long> txnIds, String dbName, String tableName) throws org.apache.thrift.TException
IMetaStoreClient
allocateTableWriteIdsBatch
in interface IMetaStoreClient
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
public List<TxnToWriteId> replAllocateTableWriteIdsBatch(String dbName, String tableName, String replPolicy, List<TxnToWriteId> srcTxnToWriteIdList) throws org.apache.thrift.TException
IMetaStoreClient
replAllocateTableWriteIdsBatch
in interface IMetaStoreClient
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
public LockResponse lock(LockRequest request) throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
IMetaStoreClient
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, IMetaStoreClient.heartbeat(long, long)
must be called
on a regular basis to avoid the lock being timed out by the system.
lock
in interface IMetaStoreClient
request
- The lock request. LockRequestBuilder
can be used
construct this request.IMetaStoreClient.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
public LockResponse checkLock(long lockid) throws NoSuchTxnException, TxnAbortedException, NoSuchLockException, org.apache.thrift.TException
IMetaStoreClient
IMetaStoreClient.lock(org.apache.hadoop.hive.metastore.api.LockRequest)
call.
Once a lock is acquired, IMetaStoreClient.heartbeat(long, long)
must be called
on a regular basis to avoid the lock being timed out by the system.checkLock
in interface IMetaStoreClient
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
public void unlock(long lockid) throws NoSuchLockException, TxnOpenException, org.apache.thrift.TException
IMetaStoreClient
unlock
in interface IMetaStoreClient
lockid
- lock id returned by
IMetaStoreClient.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 public ShowLocksResponse showLocks() throws org.apache.thrift.TException
IMetaStoreClient
showLocks
in interface IMetaStoreClient
org.apache.thrift.TException
public ShowLocksResponse showLocks(ShowLocksRequest request) throws org.apache.thrift.TException
IMetaStoreClient
showLocks
in interface IMetaStoreClient
request
- SHOW LOCK requestorg.apache.thrift.TException
public void heartbeat(long txnid, long lockid) throws NoSuchLockException, NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
IMetaStoreClient
heartbeat
in interface IMetaStoreClient
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.NoSuchLockException
- if the requested lockid does not exist.
This can result from the lock timing out and being unlocked by the system.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
public HeartbeatTxnRangeResponse heartbeatTxnRange(long min, long max) throws NoSuchTxnException, TxnAbortedException, org.apache.thrift.TException
IMetaStoreClient
IMetaStoreClient.heartbeat(long, long)
.heartbeatTxnRange
in interface IMetaStoreClient
min
- minimum transaction id to heartbeat, inclusivemax
- maximum transaction id to heartbeat, inclusiveorg.apache.thrift.TException
NoSuchTxnException
TxnAbortedException
@Deprecated public void compact(String dbname, String tableName, String partitionName, CompactionType type) throws org.apache.thrift.TException
IMetaStoreClient
compact
in interface IMetaStoreClient
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 public void compact(String dbname, String tableName, String partitionName, CompactionType type, Map<String,String> tblproperties) throws org.apache.thrift.TException
compact
in interface IMetaStoreClient
org.apache.thrift.TException
public CompactionResponse compact2(String dbname, String tableName, String partitionName, CompactionType type, Map<String,String> tblproperties) throws org.apache.thrift.TException
IMetaStoreClient
compact2
in interface IMetaStoreClient
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
public ShowCompactResponse showCompactions() throws org.apache.thrift.TException
IMetaStoreClient
showCompactions
in interface IMetaStoreClient
org.apache.thrift.TException
@Deprecated public void addDynamicPartitions(long txnId, long writeId, String dbName, String tableName, List<String> partNames) throws org.apache.thrift.TException
addDynamicPartitions
in interface IMetaStoreClient
org.apache.thrift.TException
public void addDynamicPartitions(long txnId, long writeId, String dbName, String tableName, List<String> partNames, DataOperationType operationType) throws org.apache.thrift.TException
IMetaStoreClient
addDynamicPartitions
in interface IMetaStoreClient
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
public void insertTable(Table table, boolean overwrite) throws MetaException
IMetaStoreClient
insertTable
in interface IMetaStoreClient
table
- table nameoverwrite
- true if the insert is overwriteMetaException
@InterfaceAudience.LimitedPrivate(value="HCatalog") public NotificationEventResponse getNextNotification(long lastEventId, int maxEvents, IMetaStoreClient.NotificationFilter filter) throws org.apache.thrift.TException
IMetaStoreClient
getNextNotification
in interface IMetaStoreClient
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") public CurrentNotificationEventId getCurrentNotificationEventId() throws org.apache.thrift.TException
IMetaStoreClient
getCurrentNotificationEventId
in interface IMetaStoreClient
org.apache.thrift.TException
@InterfaceAudience.LimitedPrivate(value="HCatalog") public NotificationEventsCountResponse getNotificationEventsCount(NotificationEventsCountRequest rqst) throws org.apache.thrift.TException
IMetaStoreClient
getNotificationEventsCount
in interface IMetaStoreClient
org.apache.thrift.TException
@InterfaceAudience.LimitedPrivate(value="Apache Hive, HCatalog") public FireEventResponse fireListenerEvent(FireEventRequest rqst) throws org.apache.thrift.TException
IMetaStoreClient
fireListenerEvent
in interface IMetaStoreClient
org.apache.thrift.TException
public static IMetaStoreClient newSynchronizedClient(IMetaStoreClient client)
IMetaStoreClient
.
This may be used by multi-threaded applications until we have
fixed all reentrancy bugs.client
- unsynchronized clientpublic void markPartitionForEvent(String db_name, String tbl_name, Map<String,String> partKVs, PartitionEventType eventType) throws org.apache.thrift.TException
IMetaStoreClient
markPartitionForEvent
in interface IMetaStoreClient
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 invalidpublic void markPartitionForEvent(String catName, String db_name, String tbl_name, Map<String,String> partKVs, PartitionEventType eventType) throws org.apache.thrift.TException
IMetaStoreClient
markPartitionForEvent
in interface IMetaStoreClient
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 invalidpublic boolean isPartitionMarkedForEvent(String db_name, String tbl_name, Map<String,String> partKVs, PartitionEventType eventType) throws org.apache.thrift.TException
IMetaStoreClient
isPartitionMarkedForEvent
in interface IMetaStoreClient
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 invalidpublic boolean isPartitionMarkedForEvent(String catName, String db_name, String tbl_name, Map<String,String> partKVs, PartitionEventType eventType) throws org.apache.thrift.TException
IMetaStoreClient
isPartitionMarkedForEvent
in interface IMetaStoreClient
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 invalidpublic void createFunction(Function func) throws org.apache.thrift.TException
IMetaStoreClient
createFunction
in interface IMetaStoreClient
func
- function specificationInvalidObjectException
- the function object is invalidMetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorpublic void alterFunction(String dbName, String funcName, Function newFunction) throws org.apache.thrift.TException
IMetaStoreClient
alterFunction
in interface IMetaStoreClient
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 errorpublic void alterFunction(String catName, String dbName, String funcName, Function newFunction) throws org.apache.thrift.TException
IMetaStoreClient
alterFunction
in interface IMetaStoreClient
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 errorpublic void dropFunction(String dbName, String funcName) throws org.apache.thrift.TException
IMetaStoreClient
dropFunction
in interface IMetaStoreClient
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 errorpublic void dropFunction(String catName, String dbName, String funcName) throws org.apache.thrift.TException
IMetaStoreClient
dropFunction
in interface IMetaStoreClient
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 errorpublic Function getFunction(String dbName, String funcName) throws org.apache.thrift.TException
IMetaStoreClient
getFunction
in interface IMetaStoreClient
dbName
- database name.funcName
- function name.MetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorpublic Function getFunction(String catName, String dbName, String funcName) throws org.apache.thrift.TException
IMetaStoreClient
getFunction
in interface IMetaStoreClient
catName
- catalog name.dbName
- database name.funcName
- function name.MetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorpublic List<String> getFunctions(String dbName, String pattern) throws org.apache.thrift.TException
IMetaStoreClient
getFunctions
in interface IMetaStoreClient
dbName
- database name.pattern
- to match. This is a java regex pattern.MetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorpublic List<String> getFunctions(String catName, String dbName, String pattern) throws org.apache.thrift.TException
IMetaStoreClient
getFunctions
in interface IMetaStoreClient
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 errorpublic GetAllFunctionsResponse getAllFunctions() throws org.apache.thrift.TException
IMetaStoreClient
getAllFunctions
in interface IMetaStoreClient
MetaException
- error accessing the RDBMSorg.apache.thrift.TException
- thrift transport errorprotected void create_table_with_environment_context(Table tbl, EnvironmentContext envContext) throws AlreadyExistsException, InvalidObjectException, MetaException, NoSuchObjectException, org.apache.thrift.TException
AlreadyExistsException
InvalidObjectException
MetaException
NoSuchObjectException
org.apache.thrift.TException
protected void drop_table_with_environment_context(String catName, String dbname, String name, boolean deleteData, EnvironmentContext envContext) throws org.apache.thrift.TException
org.apache.thrift.TException
public AggrStats getAggrColStatsFor(String dbName, String tblName, List<String> colNames, List<String> partNames) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
IMetaStoreClient
getAggrColStatsFor
in interface IMetaStoreClient
dbName
- 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 exceptionpublic AggrStats getAggrColStatsFor(String catName, String dbName, String tblName, List<String> colNames, List<String> partNames) throws org.apache.thrift.TException
IMetaStoreClient
getAggrColStatsFor
in interface IMetaStoreClient
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 exceptionpublic Iterable<Map.Entry<Long,ByteBuffer>> getFileMetadata(List<Long> fileIds) throws org.apache.thrift.TException
IMetaStoreClient
getFileMetadata
in interface IMetaStoreClient
org.apache.thrift.TException
public Iterable<Map.Entry<Long,MetadataPpdResult>> getFileMetadataBySarg(List<Long> fileIds, ByteBuffer sarg, boolean doGetFooters) throws org.apache.thrift.TException
getFileMetadataBySarg
in interface IMetaStoreClient
org.apache.thrift.TException
public void clearFileMetadata(List<Long> fileIds) throws org.apache.thrift.TException
IMetaStoreClient
clearFileMetadata
in interface IMetaStoreClient
org.apache.thrift.TException
public void putFileMetadata(List<Long> fileIds, List<ByteBuffer> metadata) throws org.apache.thrift.TException
IMetaStoreClient
putFileMetadata
in interface IMetaStoreClient
org.apache.thrift.TException
public boolean isSameConfObj(org.apache.hadoop.conf.Configuration c)
isSameConfObj
in interface IMetaStoreClient
public boolean cacheFileMetadata(String dbName, String tableName, String partName, boolean allParts) throws org.apache.thrift.TException
cacheFileMetadata
in interface IMetaStoreClient
org.apache.thrift.TException
public String getMetastoreDbUuid() throws org.apache.thrift.TException
IMetaStoreClient
getMetastoreDbUuid
in interface IMetaStoreClient
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 errorspublic void createResourcePlan(WMResourcePlan resourcePlan, String copyFromName) throws InvalidObjectException, MetaException, org.apache.thrift.TException
createResourcePlan
in interface IMetaStoreClient
InvalidObjectException
MetaException
org.apache.thrift.TException
public WMFullResourcePlan getResourcePlan(String resourcePlanName) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
getResourcePlan
in interface IMetaStoreClient
NoSuchObjectException
MetaException
org.apache.thrift.TException
public List<WMResourcePlan> getAllResourcePlans() throws NoSuchObjectException, MetaException, org.apache.thrift.TException
getAllResourcePlans
in interface IMetaStoreClient
NoSuchObjectException
MetaException
org.apache.thrift.TException
public void dropResourcePlan(String resourcePlanName) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
dropResourcePlan
in interface IMetaStoreClient
NoSuchObjectException
MetaException
org.apache.thrift.TException
public WMFullResourcePlan alterResourcePlan(String resourcePlanName, WMNullableResourcePlan resourcePlan, boolean canActivateDisabled, boolean isForceDeactivate, boolean isReplace) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
alterResourcePlan
in interface IMetaStoreClient
NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
public WMFullResourcePlan getActiveResourcePlan() throws MetaException, org.apache.thrift.TException
getActiveResourcePlan
in interface IMetaStoreClient
MetaException
org.apache.thrift.TException
public WMValidateResourcePlanResponse validateResourcePlan(String resourcePlanName) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
validateResourcePlan
in interface IMetaStoreClient
NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
public void createWMTrigger(WMTrigger trigger) throws InvalidObjectException, MetaException, org.apache.thrift.TException
createWMTrigger
in interface IMetaStoreClient
InvalidObjectException
MetaException
org.apache.thrift.TException
public void alterWMTrigger(WMTrigger trigger) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
alterWMTrigger
in interface IMetaStoreClient
NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
public void dropWMTrigger(String resourcePlanName, String triggerName) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
dropWMTrigger
in interface IMetaStoreClient
NoSuchObjectException
MetaException
org.apache.thrift.TException
public List<WMTrigger> getTriggersForResourcePlan(String resourcePlan) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
getTriggersForResourcePlan
in interface IMetaStoreClient
NoSuchObjectException
MetaException
org.apache.thrift.TException
public void createWMPool(WMPool pool) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
createWMPool
in interface IMetaStoreClient
NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
public void alterWMPool(WMNullablePool pool, String poolPath) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
alterWMPool
in interface IMetaStoreClient
NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
public void dropWMPool(String resourcePlanName, String poolPath) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
dropWMPool
in interface IMetaStoreClient
NoSuchObjectException
MetaException
org.apache.thrift.TException
public void createOrUpdateWMMapping(WMMapping mapping, boolean isUpdate) throws NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
createOrUpdateWMMapping
in interface IMetaStoreClient
NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
public void dropWMMapping(WMMapping mapping) throws NoSuchObjectException, MetaException, org.apache.thrift.TException
dropWMMapping
in interface IMetaStoreClient
NoSuchObjectException
MetaException
org.apache.thrift.TException
public void createOrDropTriggerToPoolMapping(String resourcePlanName, String triggerName, String poolPath, boolean shouldDrop) throws AlreadyExistsException, NoSuchObjectException, InvalidObjectException, MetaException, org.apache.thrift.TException
createOrDropTriggerToPoolMapping
in interface IMetaStoreClient
AlreadyExistsException
NoSuchObjectException
InvalidObjectException
MetaException
org.apache.thrift.TException
public void createISchema(ISchema schema) throws org.apache.thrift.TException
IMetaStoreClient
createISchema
in interface IMetaStoreClient
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 errorpublic void alterISchema(String catName, String dbName, String schemaName, ISchema newSchema) throws org.apache.thrift.TException
IMetaStoreClient
alterISchema
in interface IMetaStoreClient
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 errorpublic ISchema getISchema(String catName, String dbName, String name) throws org.apache.thrift.TException
IMetaStoreClient
getISchema
in interface IMetaStoreClient
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 errorpublic void dropISchema(String catName, String dbName, String name) throws org.apache.thrift.TException
IMetaStoreClient
dropISchema
in interface IMetaStoreClient
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 errorpublic void addSchemaVersion(SchemaVersion schemaVersion) throws org.apache.thrift.TException
IMetaStoreClient
addSchemaVersion
in interface IMetaStoreClient
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 errorpublic SchemaVersion getSchemaVersion(String catName, String dbName, String schemaName, int version) throws org.apache.thrift.TException
IMetaStoreClient
getSchemaVersion
in interface IMetaStoreClient
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 errorpublic SchemaVersion getSchemaLatestVersion(String catName, String dbName, String schemaName) throws org.apache.thrift.TException
IMetaStoreClient
getSchemaLatestVersion
in interface IMetaStoreClient
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 errorpublic List<SchemaVersion> getSchemaAllVersions(String catName, String dbName, String schemaName) throws org.apache.thrift.TException
IMetaStoreClient
getSchemaAllVersions
in interface IMetaStoreClient
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 errorpublic void dropSchemaVersion(String catName, String dbName, String schemaName, int version) throws org.apache.thrift.TException
IMetaStoreClient
dropSchemaVersion
in interface IMetaStoreClient
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 errorpublic FindSchemasByColsResp getSchemaByCols(FindSchemasByColsRqst rqst) throws org.apache.thrift.TException
IMetaStoreClient
getSchemaByCols
in interface IMetaStoreClient
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 errorpublic void mapSchemaVersionToSerde(String catName, String dbName, String schemaName, int version, String serdeName) throws org.apache.thrift.TException
IMetaStoreClient
mapSchemaVersionToSerde
in interface IMetaStoreClient
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 errorpublic void setSchemaVersionState(String catName, String dbName, String schemaName, int version, SchemaVersionState state) throws org.apache.thrift.TException
IMetaStoreClient
setSchemaVersionState
in interface IMetaStoreClient
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 errorpublic void addSerDe(SerDeInfo serDeInfo) throws org.apache.thrift.TException
IMetaStoreClient
addSerDe
in interface IMetaStoreClient
serDeInfo
- serde to addAlreadyExistsException
- serde of this name already existsMetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorpublic SerDeInfo getSerDe(String serDeName) throws org.apache.thrift.TException
IMetaStoreClient
getSerDe
in interface IMetaStoreClient
serDeName
- name of the serdeNoSuchObjectException
- no serde with this name exists.MetaException
- general metastore errororg.apache.thrift.TException
- general thrift errorpublic LockResponse lockMaterializationRebuild(String dbName, String tableName, long txnId) throws org.apache.thrift.TException
IMetaStoreClient
lockMaterializationRebuild
in interface IMetaStoreClient
dbName
- db name for the materialized viewtableName
- table name for the materialized viewtxnId
- transaction id for the rebuildorg.apache.thrift.TException
public boolean heartbeatLockMaterializationRebuild(String dbName, String tableName, long txnId) throws org.apache.thrift.TException
IMetaStoreClient
heartbeatLockMaterializationRebuild
in interface IMetaStoreClient
dbName
- db name for the materialized viewtableName
- table name for the materialized viewtxnId
- transaction id for the rebuildorg.apache.thrift.TException
public void addRuntimeStat(RuntimeStat stat) throws org.apache.thrift.TException
IMetaStoreClient
addRuntimeStat
in interface IMetaStoreClient
org.apache.thrift.TException
public List<RuntimeStat> getRuntimeStats(int maxWeight, int maxCreateTime) throws org.apache.thrift.TException
IMetaStoreClient
getRuntimeStats
in interface IMetaStoreClient
org.apache.thrift.TException
Copyright © 2022 The Apache Software Foundation. All rights reserved.