Hive (Hive 3.1.1 API)

java.lang.Object
- org.apache.hadoop.hive.ql.metadata.Hive

```
public class Hive
extends Object
```
This class has functions that implement meta data/DDL operations using calls to the metastore. It has a metastore client instance it uses to communicate with the metastore. It is a thread local variable, and the instances is accessed using static get methods in this class.

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class Hive.SchemaException

Nested Classes
Modifier and Type	Class and Description
`static class`	`Hive.SchemaException`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method and Description
`void`	`abortTransactions(List<Long> txnids)`
`void`	`addCheckConstraint(List<org.apache.hadoop.hive.metastore.api.SQLCheckConstraint> checkConstraints)`
`void`	`addDefaultConstraint(List<org.apache.hadoop.hive.metastore.api.SQLDefaultConstraint> defaultConstraints)`
`void`	`addForeignKey(List<org.apache.hadoop.hive.metastore.api.SQLForeignKey> foreignKeyCols)`
`void`	`addNotNullConstraint(List<org.apache.hadoop.hive.metastore.api.SQLNotNullConstraint> notNullConstraintCols)`
`void`	`addPrimaryKey(List<org.apache.hadoop.hive.metastore.api.SQLPrimaryKey> primaryKeyCols)`
`void`	`addUniqueConstraint(List<org.apache.hadoop.hive.metastore.api.SQLUniqueConstraint> uniqueConstraintCols)`
`void`	`alterDatabase(String dbName, org.apache.hadoop.hive.metastore.api.Database db)`
`void`	`alterFunction(String dbName, String funcName, org.apache.hadoop.hive.metastore.api.Function newFunction)`
`void`	`alterPartition(String tblName, Partition newPart, org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)` Updates the existing partition metadata with the new metadata.
`void`	`alterPartition(String dbName, String tblName, Partition newPart, org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)` Updates the existing partition metadata with the new metadata.
`void`	`alterPartitions(String tblName, List<Partition> newParts, org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)` Updates the existing table metadata with the new metadata.
`org.apache.hadoop.hive.metastore.api.WMFullResourcePlan`	`alterResourcePlan(String rpName, org.apache.hadoop.hive.metastore.api.WMNullableResourcePlan resourcePlan, boolean canActivateDisabled, boolean isForceDeactivate, boolean isReplace)`
`void`	`alterTable(String dbName, String tblName, Table newTbl, boolean cascade, org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)`
`void`	`alterTable(String fullyQlfdTblName, Table newTbl, boolean cascade, org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)`
`void`	`alterTable(String fullyQlfdTblName, Table newTbl, org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)` Updates the existing table metadata with the new metadata.
`void`	`alterTable(Table newTbl, org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)`
`void`	`alterWMPool(org.apache.hadoop.hive.metastore.api.WMNullablePool pool, String poolPath)`
`void`	`alterWMTrigger(org.apache.hadoop.hive.metastore.api.WMTrigger trigger)`
`void`	`cacheFileMetadata(String dbName, String tableName, String partName, boolean allParts)`
`void`	`cancelDelegationToken(String tokenStrForm)`
`static void`	`clearDestForSubDirSrc(HiveConf conf, org.apache.hadoop.fs.Path dest, org.apache.hadoop.fs.Path src, boolean isSrcLocal)`
`void`	`clearFileMetadata(List<Long> fileIds)`
`void`	`clearMetaCallTiming()`
`static void`	`closeCurrent()`
`void`	`compact(String dbname, String tableName, String partName, String compactType, Map<String,String> tblproperties)` Deprecated. use `compact2(String, String, String, String, Map)`
`org.apache.hadoop.hive.metastore.api.CompactionResponse`	`compact2(String dbname, String tableName, String partName, String compactType, Map<String,String> tblproperties)` Enqueue a compaction request.
`static org.apache.hadoop.hive.metastore.api.Partition`	`convertAddSpecToMetaPartition(Table tbl, AddPartitionDesc.OnePartitionDesc addSpec, HiveConf conf)`
`protected static void`	`copyFiles(HiveConf conf, org.apache.hadoop.fs.Path srcf, org.apache.hadoop.fs.Path destf, org.apache.hadoop.fs.FileSystem fs, boolean isSrcLocal, boolean isAcidIUD, boolean isOverwrite, List<org.apache.hadoop.fs.Path> newFiles, boolean isBucketed, boolean isFullAcidTable, boolean isManaged)` Copy files.
`void`	`createDatabase(org.apache.hadoop.hive.metastore.api.Database db)` Create a Database.
`void`	`createDatabase(org.apache.hadoop.hive.metastore.api.Database db, boolean ifNotExist)` Create a database
`void`	`createFunction(org.apache.hadoop.hive.metastore.api.Function func)`
`void`	`createOrDropTriggerToPoolMapping(String resourcePlanName, String triggerName, String poolPath, boolean shouldDrop)`
`void`	`createOrUpdateWMMapping(org.apache.hadoop.hive.metastore.api.WMMapping mapping, boolean isUpdate)`
`Partition`	`createPartition(Table tbl, Map<String,String> partSpec)` Creates a partition.
`List<Partition>`	`createPartitions(AddPartitionDesc addPartitionDesc)`
`void`	`createResourcePlan(org.apache.hadoop.hive.metastore.api.WMResourcePlan resourcePlan, String copyFromName)`
`void`	`createRole(String roleName, String ownerName)`
`void`	`createTable(String tableName, List<String> columns, List<String> partCols, Class<? extends org.apache.hadoop.mapred.InputFormat> fileInputFormat, Class<?> fileOutputFormat)` Creates a table metadata and the directory for the table data
`void`	`createTable(String tableName, List<String> columns, List<String> partCols, Class<? extends org.apache.hadoop.mapred.InputFormat> fileInputFormat, Class<?> fileOutputFormat, int bucketCount, List<String> bucketCols)` Creates a table metadata and the directory for the table data
`void`	`createTable(String tableName, List<String> columns, List<String> partCols, Class<? extends org.apache.hadoop.mapred.InputFormat> fileInputFormat, Class<?> fileOutputFormat, int bucketCount, List<String> bucketCols, Map<String,String> parameters)` Create a table metadata and the directory for the table data
`void`	`createTable(Table tbl)` Creates the table with the give objects
`void`	`createTable(Table tbl, boolean ifNotExists)`
`void`	createTable(Table tbl, boolean ifNotExists, List<org.apache.hadoop.hive.metastore.api.SQLPrimaryKey> primaryKeys, List<org.apache.hadoop.hive.metastore.api.SQLForeignKey> foreignKeys, List<org.apache.hadoop.hive.metastore.api.SQLUniqueConstraint> uniqueConstraints, List<org.apache.hadoop.hive.metastore.api.SQLNotNullConstraint> notNullConstraints, List<org.apache.hadoop.hive.metastore.api.SQLDefaultConstraint> defaultConstraints, List<org.apache.hadoop.hive.metastore.api.SQLCheckConstraint> checkConstraints) Creates the table with the given objects.
`void`	`createWMPool(org.apache.hadoop.hive.metastore.api.WMPool pool)`
`void`	`createWMTrigger(org.apache.hadoop.hive.metastore.api.WMTrigger trigger)`
`boolean`	`databaseExists(String dbName)` Query metadata to see if a database with the given name already exists.
`boolean`	`deletePartitionColumnStatistics(String dbName, String tableName, String partName, String colName)`
`boolean`	`deleteTableColumnStatistics(String dbName, String tableName, String colName)`
`void`	`dropConstraint(String dbName, String tableName, String constraintName)`
`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`	`dropFunction(String dbName, String funcName)`
`boolean`	`dropPartition(String tblName, List<String> part_vals, boolean deleteData)`
`boolean`	`dropPartition(String db_name, String tbl_name, List<String> part_vals, boolean deleteData)`
`boolean`	`dropPartition(String dbName, String tableName, List<String> partVals, PartitionDropOptions options)`
`List<Partition>`	`dropPartitions(String tblName, List<DropTableDesc.PartSpec> partSpecs, boolean deleteData, boolean ifExists)`
`List<Partition>`	`dropPartitions(String tblName, List<DropTableDesc.PartSpec> partSpecs, PartitionDropOptions dropOptions)`
`List<Partition>`	`dropPartitions(String dbName, String tblName, List<DropTableDesc.PartSpec> partSpecs, boolean deleteData, boolean ifExists)`
`List<Partition>`	`dropPartitions(String dbName, String tblName, List<DropTableDesc.PartSpec> partSpecs, PartitionDropOptions dropOptions)`
`List<Partition>`	`dropPartitions(Table table, List<String> partDirNames, boolean deleteData, boolean ifExists)` drop the partitions specified as directory names associated with the table.
`void`	`dropResourcePlan(String rpName)`
`void`	`dropRole(String roleName)`
`void`	`dropTable(String tableName)` Drops table along with the data in it.
`void`	`dropTable(String tableName, boolean ifPurge)` Drops table along with the data in it.
`void`	`dropTable(String dbName, String tableName)` Drops table along with the data in it.
`void`	`dropTable(String dbName, String tableName, boolean deleteData, boolean ignoreUnknownTab)` Drops the table.
`void`	`dropTable(String dbName, String tableName, boolean deleteData, boolean ignoreUnknownTab, boolean ifPurge)` Drops the table.
`void`	`dropWMMapping(org.apache.hadoop.hive.metastore.api.WMMapping mapping)`
`void`	`dropWMPool(String resourcePlanName, String poolPath)`
`void`	`dropWMTrigger(String rpName, String triggerName)`
`com.google.common.collect.ImmutableMap<String,Long>`	`dumpAndClearMetaCallTiming(String phase)`
`List<Partition>`	`exchangeTablePartitions(Map<String,String> partitionSpecs, String sourceDb, String sourceTable, String destDb, String destinationTableName)`
`org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet`	`get_privilege_set(org.apache.hadoop.hive.metastore.api.HiveObjectType objectType, String db_name, String table_name, List<String> part_values, String column_name, String user_name, List<String> group_names)`
`static Hive`	`get()`
`static Hive`	`get(boolean doRegisterAllFns)`
`static Hive`	`get(org.apache.hadoop.conf.Configuration c, Class<?> clazz)`
`static Hive`	`get(HiveConf c)` Gets hive object for the current thread.
`static Hive`	`get(HiveConf c, boolean needsRefresh)` get a connection to metastore.
`org.apache.hadoop.hive.metastore.api.WMFullResourcePlan`	`getActiveResourcePlan()`
`org.apache.hadoop.hive.metastore.api.AggrStats`	`getAggrColStatsFor(String dbName, String tblName, List<String> colNames, List<String> partName)`
`List<String>`	`getAllDatabases()` Get all existing database names.
`List<org.apache.hadoop.hive.metastore.api.Function>`	`getAllFunctions()`
`List<Table>`	`getAllMaterializedViewObjects(String dbName)` Get all materialized views for the specified database.
`List<String>`	`getAllMaterializedViews(String dbName)` Get all materialized view names for the specified database.
`Set<Partition>`	`getAllPartitionsOf(Table tbl)` Get all the partitions; unlike `getPartitions(Table)`, does not include auth.
`List<org.apache.hadoop.hive.metastore.api.WMResourcePlan>`	`getAllResourcePlans()`
`List<String>`	`getAllRoleNames()` Get all existing role names.
`List<Table>`	`getAllTableObjects(String dbName)` Get all tables for the specified database.
`List<String>`	`getAllTables()` Get all table names for the current database.
`List<String>`	`getAllTables(String dbName)` Get all table names for the specified database.
`List<org.apache.calcite.plan.RelOptMaterialization>`	`getAllValidMaterializedViews(List<String> tablesUsed, boolean forceMVContentsUpToDate)` Get the materialized views that have been enabled for rewriting from the metastore.
`List<org.apache.hadoop.hive.metastore.api.SQLCheckConstraint>`	`getCheckConstraintList(String dbName, String tblName)`
`CheckConstraint`	`getCheckConstraints(String dbName, String tblName)`
`HiveConf`	`getConf()`
`org.apache.hadoop.hive.metastore.api.Database`	`getDatabase(String dbName)` Get the database by name.
`org.apache.hadoop.hive.metastore.api.Database`	`getDatabase(String catName, String dbName)` Get the database by name.
`org.apache.hadoop.hive.metastore.api.Database`	`getDatabaseCurrent()` Get the Database object for current database
`List<String>`	`getDatabasesByPattern(String databasePattern)` Get all existing databases that match the given pattern.
`List<org.apache.hadoop.hive.metastore.api.SQLDefaultConstraint>`	`getDefaultConstraintList(String dbName, String tblName)`
`DefaultConstraint`	`getDefaultConstraints(String dbName, String tblName)`
`String`	`getDelegationToken(String owner, String renewer)`
`CheckConstraint`	`getEnabledCheckConstraints(String dbName, String tblName)` Get CHECK constraints associated with the table that are enabled
`DefaultConstraint`	`getEnabledDefaultConstraints(String dbName, String tblName)` Get Default constraints associated with the table that are enabled
`NotNullConstraint`	`getEnabledNotNullConstraints(String dbName, String tblName)` Get not null constraints associated with the table that are enabled/enforced.
`static List<org.apache.hadoop.hive.metastore.api.FieldSchema>`	`getFieldsFromDeserializer(String name, Deserializer serde)`
`static List<org.apache.hadoop.hive.metastore.api.FieldSchema>`	`getFieldsFromDeserializerForMsStorage(Table tbl, Deserializer deserializer)`
`Iterable<Map.Entry<Long,ByteBuffer>>`	`getFileMetadata(List<Long> fileIds)`
`Iterable<Map.Entry<Long,org.apache.hadoop.hive.metastore.api.MetadataPpdResult>>`	`getFileMetadataByExpr(List<Long> fileIds, ByteBuffer sarg, boolean doGetFooters)`
`List<org.apache.hadoop.hive.metastore.api.SQLForeignKey>`	`getForeignKeyList(String dbName, String tblName)`
`ForeignKeyInfo`	`getForeignKeys(String dbName, String tblName)` Get all foreign keys associated with the table.
`org.apache.hadoop.hive.metastore.api.Function`	`getFunction(String dbName, String funcName)`
`List<String>`	`getFunctions(String dbName, String pattern)`
`String`	`getMetaConf(String propName)`
`IMetaStoreClient`	`getMSC()`
`IMetaStoreClient`	`getMSC(boolean allowEmbedded, boolean forceCreate)`
`List<org.apache.hadoop.hive.metastore.api.SQLNotNullConstraint>`	`getNotNullConstraintList(String dbName, String tblName)`
`NotNullConstraint`	`getNotNullConstraints(String dbName, String tblName)` Get all not null constraints associated with the table.
`int`	`getNumPartitionsByFilter(Table tbl, String filter)` Get a number of Partitions by filter.
`Partition`	`getPartition(Table tbl, Map<String,String> partSpec, boolean forceCreate)`
`Partition`	`getPartition(Table tbl, Map<String,String> partSpec, boolean forceCreate, String partPath, boolean inheritTableSpecs)` Returns partition metadata
`Map<String,List<org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj>>`	`getPartitionColumnStatistics(String dbName, String tableName, List<String> partNames, List<String> colNames)`
`List<String>`	`getPartitionNames(String tblName, short max)`
`List<String>`	`getPartitionNames(String dbName, String tblName, Map<String,String> partSpec, short max)`
`List<String>`	`getPartitionNames(String dbName, String tblName, short max)`
`List<Partition>`	`getPartitions(Table tbl)` get all the partitions that the table has
`List<Partition>`	`getPartitions(Table tbl, Map<String,String> partialPartSpec)` get all the partitions of the table that matches the given partial specification.
`List<Partition>`	`getPartitions(Table tbl, Map<String,String> partialPartSpec, short limit)` get all the partitions of the table that matches the given partial specification.
`boolean`	`getPartitionsByExpr(Table tbl, ExprNodeGenericFuncDesc expr, HiveConf conf, List<Partition> result)` Get a list of Partitions by expr.
`List<Partition>`	`getPartitionsByFilter(Table tbl, String filter)` Get a list of Partitions by filter.
`List<Partition>`	`getPartitionsByNames(Table tbl, List<String> partNames)` Get all partitions of the table that matches the list of given partition names.
`List<Partition>`	`getPartitionsByNames(Table tbl, Map<String,String> partialPartSpec)` get all the partitions of the table that matches the given partial specification.
`List<org.apache.hadoop.hive.metastore.api.SQLPrimaryKey>`	`getPrimaryKeyList(String dbName, String tblName)`
`PrimaryKeyInfo`	`getPrimaryKeys(String dbName, String tblName)` Get all primary key columns associated with the table.
`ForeignKeyInfo`	`getReliableForeignKeys(String dbName, String tblName)` Get foreign keys associated with the table that are available for optimization.
`NotNullConstraint`	`getReliableNotNullConstraints(String dbName, String tblName)` Get not null constraints associated with the table that are available for optimization.
`PrimaryKeyInfo`	`getReliablePrimaryKeys(String dbName, String tblName)` Get primary key columns associated with the table that are available for optimization.
`UniqueConstraint`	`getReliableUniqueConstraints(String dbName, String tblName)` Get unique constraints associated with the table that are available for optimization.
`org.apache.hadoop.hive.metastore.api.WMFullResourcePlan`	`getResourcePlan(String rpName)`
`List<org.apache.hadoop.hive.metastore.api.RolePrincipalGrant>`	`getRoleGrantInfoForPrincipal(String principalName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType)`
`StorageHandlerInfo`	`getStorageHandlerInfo(Table table)`
`SynchronizedMetaStoreClient`	`getSynchronizedMSC()`
`Table`	`getTable(String tableName)` Returns metadata for the table named tableName
`Table`	`getTable(String tableName, boolean throwException)` Returns metadata for the table named tableName
`Table`	`getTable(String dbName, String tableName)` Returns metadata of the table
`Table`	`getTable(String dbName, String tableName, boolean throwException)` Returns metadata of the table
`List<org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj>`	`getTableColumnStatistics(String dbName, String tableName, List<String> colNames)`
`List<String>`	`getTablesByPattern(String tablePattern)` Returns all existing tables from default database which match the given pattern.
`List<String>`	`getTablesByPattern(String dbName, String tablePattern)` Returns all existing tables from the specified database which match the given pattern.
`List<String>`	`getTablesByType(String dbName, String pattern, TableType type)` Returns all existing tables of a type (VIRTUAL_VIEW\|EXTERNAL_TABLE\|MANAGED_TABLE) from the specified database which match the given pattern.
`List<String>`	`getTablesForDb(String database, String tablePattern)` Returns all existing tables from the given database which match the given pattern.
`List<org.apache.hadoop.hive.metastore.api.SQLUniqueConstraint>`	`getUniqueConstraintList(String dbName, String tblName)`
`UniqueConstraint`	`getUniqueConstraints(String dbName, String tblName)` Get all unique constraints associated with the table.
`List<org.apache.calcite.plan.RelOptMaterialization>`	`getValidMaterializedView(String dbName, String materializedViewName, List<String> tablesUsed, boolean forceMVContentsUpToDate)`
`static Hive`	`getWithFastCheck(HiveConf c)` Same as `get(HiveConf)`, except that it checks only the object identity of existing MS client, assuming the relevant settings would be unchanged within the same conf object.
`static Hive`	`getWithFastCheck(HiveConf c, boolean doRegisterAllFns)` Same as `get(HiveConf)`, except that it checks only the object identity of existing MS client, assuming the relevant settings would be unchanged within the same conf object.
`boolean`	`grantPrivileges(org.apache.hadoop.hive.metastore.api.PrivilegeBag privileges)`
`boolean`	`grantRole(String roleName, String userName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType, String grantor, org.apache.hadoop.hive.metastore.api.PrincipalType grantorType, boolean grantOption)`
`static boolean`	`isHadoop1()`
`static void`	`listNewFilesRecursively(org.apache.hadoop.fs.FileSystem destFs, org.apache.hadoop.fs.Path dest, List<org.apache.hadoop.fs.Path> newFiles)`
`List<org.apache.hadoop.hive.metastore.api.Role>`	`listRoles(String userName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType)`
`Map<Map<String,String>,Partition>`	`loadDynamicPartitions(org.apache.hadoop.fs.Path loadPath, String tableName, Map<String,String> partSpec, LoadTableDesc.LoadFileType loadFileType, int numDP, int numLB, boolean isAcid, long writeId, int stmtId, boolean hasFollowingStatsTask, AcidUtils.Operation operation, boolean isInsertOverwrite)` Given a source directory name of the load path, load all dynamically generated partitions into the specified table and return a list of strings that represent the dynamic partition paths.
`Partition`	`loadPartition(org.apache.hadoop.fs.Path loadPath, Table tbl, Map<String,String> partSpec, LoadTableDesc.LoadFileType loadFileType, boolean inheritTableSpecs, boolean isSkewedStoreAsSubdir, boolean isSrcLocal, boolean isAcidIUDoperation, boolean hasFollowingStatsTask, Long writeId, int stmtId, boolean isInsertOverwrite)` Load a directory into a Hive Table Partition - Alters existing content of the partition with the contents of loadPath.
`void`	`loadTable(org.apache.hadoop.fs.Path loadPath, String tableName, LoadTableDesc.LoadFileType loadFileType, boolean isSrcLocal, boolean isSkewedStoreAsSubdir, boolean isAcidIUDoperation, boolean hasFollowingStatsTask, Long writeId, int stmtId, boolean isInsertOverwrite)` Load a directory into a Hive Table.
`static void`	`moveAcidFiles(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.FileStatus[] stats, org.apache.hadoop.fs.Path dst, List<org.apache.hadoop.fs.Path> newFiles)`
`static boolean`	`moveFile(HiveConf conf, org.apache.hadoop.fs.Path srcf, org.apache.hadoop.fs.Path destf, boolean replace, boolean isSrcLocal, boolean isManaged)`
`Table`	`newTable(String tableName)`
`void`	`putFileMetadata(List<Long> fileIds, List<ByteBuffer> metadata)`
`void`	`recycleDirToCmPath(org.apache.hadoop.fs.Path dataPath, boolean isPurge)` Recycles the files recursively from the input path to the cmroot directory either by copying or moving it.
`void`	`reloadFunctions()`
`void`	`renamePartition(Table tbl, Map<String,String> oldPartSpec, Partition newPart)` Rename a old partition to new partition
`protected void`	`replaceFiles(org.apache.hadoop.fs.Path tablePath, org.apache.hadoop.fs.Path srcf, org.apache.hadoop.fs.Path destf, org.apache.hadoop.fs.Path oldPath, HiveConf conf, boolean isSrcLocal, boolean purge, List<org.apache.hadoop.fs.Path> newFiles, org.apache.hadoop.fs.PathFilter deletePathFilter, boolean isNeedRecycle, boolean isManaged)` Replaces files in the partition with new data set specified by srcf.
`boolean`	`revokePrivileges(org.apache.hadoop.hive.metastore.api.PrivilegeBag privileges, boolean grantOption)`
`boolean`	`revokeRole(String roleName, String userName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType, boolean grantOption)`
`static void`	`set(Hive hive)`
`void`	`setMetaConf(String propName, String propValue)`
`boolean`	`setPartitionColumnStatistics(org.apache.hadoop.hive.metastore.api.SetPartitionsStatsRequest request)`
`org.apache.hadoop.hive.metastore.api.ShowCompactResponse`	`showCompactions()`
`List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege>`	`showPrivilegeGrant(org.apache.hadoop.hive.metastore.api.HiveObjectType objectType, String principalName, org.apache.hadoop.hive.metastore.api.PrincipalType principalType, String dbName, String tableName, List<String> partValues, String columnName)`
`org.apache.hadoop.hive.metastore.api.GetOpenTxnsInfoResponse`	`showTransactions()`
`static boolean`	`trashFiles(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.FileStatus[] statuses, org.apache.hadoop.conf.Configuration conf, boolean purge)` Trashes or deletes all files under a directory.
`void`	`truncateTable(String dbDotTableName, Map<String,String> partSpec)` Truncates the table/partition as per specifications.
`void`	`updateCreationMetadata(String dbName, String tableName, org.apache.hadoop.hive.metastore.api.CreationMetadata cm)`
`void`	`validatePartitionNameCharacters(List<String> partVals)`
`org.apache.hadoop.hive.metastore.api.WMValidateResourcePlanResponse`	`validateResourcePlan(String rpName)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

reloadFunctions

public void reloadFunctions()
                     throws HiveException

Throws:: HiveException

get

public static Hive get(org.apache.hadoop.conf.Configuration c,
                       Class<?> clazz)
                throws HiveException

Throws:: HiveException

get
```
public static Hive get(HiveConf c)
                throws HiveException
```
Gets hive object for the current thread. If one is not initialized then a new one is created If the new configuration is different in metadata conf vars, or the owner will be different then a new one is created.

Parameters:

c - new Hive Configuration

Returns:

Hive object for current thread

Throws:

HiveException

getWithFastCheck
```
public static Hive getWithFastCheck(HiveConf c)
                             throws HiveException
```
Same as get(HiveConf), except that it checks only the object identity of existing MS client, assuming the relevant settings would be unchanged within the same conf object.

Throws:

HiveException

getWithFastCheck
```
public static Hive getWithFastCheck(HiveConf c,
                                    boolean doRegisterAllFns)
                             throws HiveException
```
Same as get(HiveConf), except that it checks only the object identity of existing MS client, assuming the relevant settings would be unchanged within the same conf object.

Throws:

HiveException

get

public static Hive get()
                throws HiveException

Throws:: HiveException

get

public static Hive get(boolean doRegisterAllFns)
                throws HiveException

Throws:: HiveException

get
```
public static Hive get(HiveConf c,
                       boolean needsRefresh)
                throws HiveException
```
get a connection to metastore. see get(HiveConf) function for comments

Parameters:

c - new conf

needsRefresh - if true then creates a new one

Returns:

The connection to the metastore

Throws:

HiveException

set
```
public static void set(Hive hive)
```

closeCurrent
```
public static void closeCurrent()
```

createDatabase

public void createDatabase(org.apache.hadoop.hive.metastore.api.Database db,
                           boolean ifNotExist)
                    throws org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                           HiveException

Create a database

Parameters:: db -; ifNotExist - if true, will ignore AlreadyExistsException exception
Throws:: org.apache.hadoop.hive.metastore.api.AlreadyExistsException; HiveException

createDatabase

public void createDatabase(org.apache.hadoop.hive.metastore.api.Database db)
                    throws org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                           HiveException

Create a Database. Raise an error if a database with the same name already exists.

Parameters:: db -
Throws:: org.apache.hadoop.hive.metastore.api.AlreadyExistsException; HiveException

dropDatabase
```
public void dropDatabase(String name)
                  throws HiveException,
                         org.apache.hadoop.hive.metastore.api.NoSuchObjectException
```
Drop a database.

Parameters:

name -

Throws:

org.apache.hadoop.hive.metastore.api.NoSuchObjectException

HiveException

See Also:

HiveMetaStoreClient.dropDatabase(java.lang.String)

dropDatabase

public void dropDatabase(String name,
                         boolean deleteData,
                         boolean ignoreUnknownDb)
                  throws HiveException,
                         org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Drop a database

Parameters:: name -; deleteData -; ignoreUnknownDb - if true, will ignore NoSuchObjectException
Throws:: HiveException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException

dropDatabase
```
public void dropDatabase(String name,
                         boolean deleteData,
                         boolean ignoreUnknownDb,
                         boolean cascade)
                  throws HiveException,
                         org.apache.hadoop.hive.metastore.api.NoSuchObjectException
```
Drop a database

Parameters:

name -

deleteData -

ignoreUnknownDb - if true, will ignore NoSuchObjectException

cascade - if true, delete all tables on the DB if exists. Otherwise, the query will fail if table still exists.

Throws:

HiveException

org.apache.hadoop.hive.metastore.api.NoSuchObjectException

createTable
```
public void createTable(String tableName,
                        List<String> columns,
                        List<String> partCols,
                        Class<? extends org.apache.hadoop.mapred.InputFormat> fileInputFormat,
                        Class<?> fileOutputFormat)
                 throws HiveException
```
Creates a table metadata and the directory for the table data

Parameters:

tableName - name of the table

columns - list of fields of the table

partCols - partition keys of the table

fileInputFormat - Class of the input format of the table data file

fileOutputFormat - Class of the output format of the table data file

Throws:

HiveException - thrown if the args are invalid or if the metadata or the data directory couldn't be created

createTable

public void createTable(String tableName,
                        List<String> columns,
                        List<String> partCols,
                        Class<? extends org.apache.hadoop.mapred.InputFormat> fileInputFormat,
                        Class<?> fileOutputFormat,
                        int bucketCount,
                        List<String> bucketCols)
                 throws HiveException

Creates a table metadata and the directory for the table data

Parameters:: tableName - name of the table; columns - list of fields of the table; partCols - partition keys of the table; fileInputFormat - Class of the input format of the table data file; fileOutputFormat - Class of the output format of the table data file; bucketCount - number of buckets that each partition (or the table itself) should be divided into
Throws:: HiveException - thrown if the args are invalid or if the metadata or the data directory couldn't be created

createTable

public void createTable(String tableName,
                        List<String> columns,
                        List<String> partCols,
                        Class<? extends org.apache.hadoop.mapred.InputFormat> fileInputFormat,
                        Class<?> fileOutputFormat,
                        int bucketCount,
                        List<String> bucketCols,
                        Map<String,String> parameters)
                 throws HiveException

Create a table metadata and the directory for the table data

Parameters:: tableName - table name; columns - list of fields of the table; partCols - partition keys of the table; fileInputFormat - Class of the input format of the table data file; fileOutputFormat - Class of the output format of the table data file; bucketCount - number of buckets that each partition (or the table itself) should be divided into; bucketCols - Bucket columns; parameters - Parameters for the table
Throws:: HiveException

alterTable

public void alterTable(Table newTbl,
                       org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)
                throws HiveException

Throws:: HiveException

alterTable
```
public void alterTable(String fullyQlfdTblName,
                       Table newTbl,
                       org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)
                throws HiveException
```
Updates the existing table metadata with the new metadata.

Parameters:

fullyQlfdTblName - name of the existing table

newTbl - new name of the table. could be the old name

Throws:

org.apache.hadoop.hive.metastore.api.InvalidOperationException - if the changes in metadata is not acceptable

org.apache.thrift.TException

HiveException

alterTable

public void alterTable(String fullyQlfdTblName,
                       Table newTbl,
                       boolean cascade,
                       org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)
                throws HiveException

Throws:: HiveException

alterTable

public void alterTable(String dbName,
                       String tblName,
                       Table newTbl,
                       boolean cascade,
                       org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)
                throws HiveException

Throws:: HiveException

updateCreationMetadata

public void updateCreationMetadata(String dbName,
                                   String tableName,
                                   org.apache.hadoop.hive.metastore.api.CreationMetadata cm)
                            throws HiveException

Throws:: HiveException

alterPartition

public void alterPartition(String tblName,
                           Partition newPart,
                           org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)
                    throws org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                           HiveException

Updates the existing partition metadata with the new metadata.

Parameters:: tblName - name of the existing table; newPart - new partition
Throws:: org.apache.hadoop.hive.metastore.api.InvalidOperationException - if the changes in metadata is not acceptable; org.apache.thrift.TException; HiveException

alterPartition

public void alterPartition(String dbName,
                           String tblName,
                           Partition newPart,
                           org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)
                    throws org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                           HiveException

Updates the existing partition metadata with the new metadata.

Parameters:: dbName - name of the exiting table's database; tblName - name of the existing table; newPart - new partition
Throws:: org.apache.hadoop.hive.metastore.api.InvalidOperationException - if the changes in metadata is not acceptable; org.apache.thrift.TException; HiveException

alterPartitions

public void alterPartitions(String tblName,
                            List<Partition> newParts,
                            org.apache.hadoop.hive.metastore.api.EnvironmentContext environmentContext)
                     throws org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                            HiveException

Updates the existing table metadata with the new metadata.

Parameters:: tblName - name of the existing table; newParts - new partitions
Throws:: org.apache.hadoop.hive.metastore.api.InvalidOperationException - if the changes in metadata is not acceptable; org.apache.thrift.TException; HiveException

renamePartition
```
public void renamePartition(Table tbl,
                            Map<String,String> oldPartSpec,
                            Partition newPart)
                     throws HiveException
```
Rename a old partition to new partition

Parameters:

tbl - existing table

oldPartSpec - spec of old partition

newPart - new partition

Throws:

org.apache.hadoop.hive.metastore.api.InvalidOperationException - if the changes in metadata is not acceptable

org.apache.thrift.TException

HiveException

alterDatabase

public void alterDatabase(String dbName,
                          org.apache.hadoop.hive.metastore.api.Database db)
                   throws HiveException

Throws:: HiveException

createTable
```
public void createTable(Table tbl)
                 throws HiveException
```
Creates the table with the give objects

Parameters:

tbl - a table object

Throws:

HiveException

createTable

public void createTable(Table tbl,
                        boolean ifNotExists,
                        List<org.apache.hadoop.hive.metastore.api.SQLPrimaryKey> primaryKeys,
                        List<org.apache.hadoop.hive.metastore.api.SQLForeignKey> foreignKeys,
                        List<org.apache.hadoop.hive.metastore.api.SQLUniqueConstraint> uniqueConstraints,
                        List<org.apache.hadoop.hive.metastore.api.SQLNotNullConstraint> notNullConstraints,
                        List<org.apache.hadoop.hive.metastore.api.SQLDefaultConstraint> defaultConstraints,
                        List<org.apache.hadoop.hive.metastore.api.SQLCheckConstraint> checkConstraints)
                 throws HiveException

Creates the table with the given objects. It takes additional arguments for primary keys and foreign keys associated with the table.

Parameters:: tbl - a table object; ifNotExists - if true, ignore AlreadyExistsException; primaryKeys - primary key columns associated with the table; foreignKeys - foreign key columns associated with the table; uniqueConstraints - UNIQUE constraints associated with the table; notNullConstraints - NOT NULL constraints associated with the table; defaultConstraints - DEFAULT constraints associated with the table; checkConstraints - CHECK constraints associated with the table
Throws:: HiveException

createTable

public void createTable(Table tbl,
                        boolean ifNotExists)
                 throws HiveException

Throws:: HiveException

getFieldsFromDeserializerForMsStorage

public static List<org.apache.hadoop.hive.metastore.api.FieldSchema> getFieldsFromDeserializerForMsStorage(Table tbl,
                                                                                                           Deserializer deserializer)
                                                                                                    throws SerDeException,
                                                                                                           org.apache.hadoop.hive.metastore.api.MetaException

Throws:: SerDeException; org.apache.hadoop.hive.metastore.api.MetaException

dropTable
```
public void dropTable(String tableName,
                      boolean ifPurge)
               throws HiveException
```
Drops table along with the data in it. If the table doesn't exist then it is a no-op. If ifPurge option is specified it is passed to the hdfs command that removes table data from warehouse to make it skip trash.

Parameters:

tableName - table to drop

ifPurge - completely purge the table (skipping trash) while removing data from warehouse

Throws:

HiveException - thrown if the drop fails

dropTable
```
public void dropTable(String tableName)
               throws HiveException
```
Drops table along with the data in it. If the table doesn't exist then it is a no-op

Parameters:

tableName - table to drop

Throws:

HiveException - thrown if the drop fails

dropTable
```
public void dropTable(String dbName,
                      String tableName)
               throws HiveException
```
Drops table along with the data in it. If the table doesn't exist then it is a no-op

Parameters:

dbName - database where the table lives

tableName - table to drop

Throws:

HiveException - thrown if the drop fails

dropTable

public void dropTable(String dbName,
                      String tableName,
                      boolean deleteData,
                      boolean ignoreUnknownTab)
               throws HiveException

Drops the table.

Parameters:: dbName -; tableName -; deleteData - deletes the underlying data along with metadata; ignoreUnknownTab - an exception is thrown if this is false and the table doesn't exist
Throws:: HiveException

dropTable
```
public void dropTable(String dbName,
                      String tableName,
                      boolean deleteData,
                      boolean ignoreUnknownTab,
                      boolean ifPurge)
               throws HiveException
```
Drops the table.

Parameters:

dbName -

tableName -

deleteData - deletes the underlying data along with metadata

ignoreUnknownTab - an exception is thrown if this is false and the table doesn't exist

ifPurge - completely purge the table skipping trash while removing data from warehouse

Throws:

HiveException

truncateTable

public void truncateTable(String dbDotTableName,
                          Map<String,String> partSpec)
                   throws HiveException

Truncates the table/partition as per specifications. Just trash the data files

Parameters:: dbDotTableName - name of the table
Throws:: HiveException

getConf
```
public HiveConf getConf()
```

getTable
```
public Table getTable(String tableName)
               throws HiveException
```
Returns metadata for the table named tableName

Parameters:

tableName - the name of the table

Returns:

the table metadata

Throws:

HiveException - if there's an internal error or if the table doesn't exist

getTable
```
public Table getTable(String tableName,
                      boolean throwException)
               throws HiveException
```
Returns metadata for the table named tableName

Parameters:

tableName - the name of the table

throwException - controls whether an exception is thrown or a returns a null

Returns:

the table metadata

Throws:

HiveException - if there's an internal error or if the table doesn't exist

getTable
```
public Table getTable(String dbName,
                      String tableName)
               throws HiveException
```
Returns metadata of the table

Parameters:

dbName - the name of the database

tableName - the name of the table

Returns:

the table

Throws:

HiveException - if there's an internal error or if the table doesn't exist

getTable
```
public Table getTable(String dbName,
                      String tableName,
                      boolean throwException)
               throws HiveException
```
Returns metadata of the table

Parameters:

dbName - the name of the database

tableName - the name of the table

throwException - controls whether an exception is thrown or a returns a null

Returns:

the table or if throwException is false a null value.

Throws:

HiveException

getAllTables
```
public List<String> getAllTables()
                          throws HiveException
```
Get all table names for the current database.

Returns:

List of table names

Throws:

HiveException

getAllTables
```
public List<String> getAllTables(String dbName)
                          throws HiveException
```
Get all table names for the specified database.

Parameters:

dbName -

Returns:

List of table names

Throws:

HiveException

getAllTableObjects
```
public List<Table> getAllTableObjects(String dbName)
                               throws HiveException
```
Get all tables for the specified database.

Parameters:

dbName -

Returns:

List of all tables

Throws:

HiveException

getAllMaterializedViews
```
public List<String> getAllMaterializedViews(String dbName)
                                     throws HiveException
```
Get all materialized view names for the specified database.

Parameters:

dbName -

Returns:

List of materialized view table names

Throws:

HiveException

getAllMaterializedViewObjects
```
public List<Table> getAllMaterializedViewObjects(String dbName)
                                          throws HiveException
```
Get all materialized views for the specified database.

Parameters:

dbName -

Returns:

List of materialized view table objects

Throws:

HiveException

getTablesByPattern
```
public List<String> getTablesByPattern(String tablePattern)
                                throws HiveException
```
Returns all existing tables from default database which match the given pattern. The matching occurs as per Java regular expressions

Parameters:

tablePattern - java re pattern

Returns:

list of table names

Throws:

HiveException

getTablesByPattern
```
public List<String> getTablesByPattern(String dbName,
                                       String tablePattern)
                                throws HiveException
```
Returns all existing tables from the specified database which match the given pattern. The matching occurs as per Java regular expressions.

Parameters:

dbName -

tablePattern -

Returns:

list of table names

Throws:

HiveException

getTablesForDb
```
public List<String> getTablesForDb(String database,
                                   String tablePattern)
                            throws HiveException
```
Returns all existing tables from the given database which match the given pattern. The matching occurs as per Java regular expressions

Parameters:

database - the database name

tablePattern - java re pattern

Returns:

list of table names

Throws:

HiveException

getTablesByType
```
public List<String> getTablesByType(String dbName,
                                    String pattern,
                                    TableType type)
                             throws HiveException
```
Returns all existing tables of a type (VIRTUAL_VIEW|EXTERNAL_TABLE|MANAGED_TABLE) from the specified database which match the given pattern. The matching occurs as per Java regular expressions.

Parameters:

dbName - Database name to find the tables in. if null, uses the current database in this session.

pattern - A pattern to match for the table names.If null, returns all names from this DB.

type - The type of tables to return. VIRTUAL_VIEWS for views. If null, returns all tables and views.

Returns:

list of table names that match the pattern.

Throws:

HiveException

getAllValidMaterializedViews
```
public List<org.apache.calcite.plan.RelOptMaterialization> getAllValidMaterializedViews(List<String> tablesUsed,
                                                                                        boolean forceMVContentsUpToDate)
                                                                                 throws HiveException
```
Get the materialized views that have been enabled for rewriting from the metastore. If the materialized view is in the cache, we do not need to parse it to generate a logical plan for the rewriting. Instead, we return the version present in the cache. Further, information provided by the invalidation cache is useful to know whether a materialized view can be used for rewriting or not.

Returns:

the list of materialized views available for rewriting

Throws:

HiveException

getValidMaterializedView

public List<org.apache.calcite.plan.RelOptMaterialization> getValidMaterializedView(String dbName,
                                                                                    String materializedViewName,
                                                                                    List<String> tablesUsed,
                                                                                    boolean forceMVContentsUpToDate)
                                                                             throws HiveException

Throws:: HiveException

getAllDatabases
```
public List<String> getAllDatabases()
                             throws HiveException
```
Get all existing database names.

Returns:

List of database names.

Throws:

HiveException

getDatabasesByPattern
```
public List<String> getDatabasesByPattern(String databasePattern)
                                   throws HiveException
```
Get all existing databases that match the given pattern. The matching occurs as per Java regular expressions

Parameters:

databasePattern - java re pattern

Returns:

list of database names

Throws:

HiveException

grantPrivileges

public boolean grantPrivileges(org.apache.hadoop.hive.metastore.api.PrivilegeBag privileges)
                        throws HiveException

Throws:: HiveException

revokePrivileges

public boolean revokePrivileges(org.apache.hadoop.hive.metastore.api.PrivilegeBag privileges,
                                boolean grantOption)
                         throws HiveException

Parameters:: privileges - a bag of privileges
Returns:: true on success
Throws:: HiveException

databaseExists
```
public boolean databaseExists(String dbName)
                       throws HiveException
```
Query metadata to see if a database with the given name already exists.

Parameters:

dbName -

Returns:

true if a database with the given name already exists, false if does not exist.

Throws:

HiveException

getDatabase
```
public org.apache.hadoop.hive.metastore.api.Database getDatabase(String dbName)
                                                          throws HiveException
```
Get the database by name.

Parameters:

dbName - the name of the database.

Returns:

a Database object if this database exists, null otherwise.

Throws:

HiveException

getDatabase

public org.apache.hadoop.hive.metastore.api.Database getDatabase(String catName,
                                                                 String dbName)
                                                          throws HiveException

Get the database by name.

Parameters:: catName - catalog name; dbName - the name of the database.
Returns:: a Database object if this database exists, null otherwise.
Throws:: HiveException

getDatabaseCurrent

public org.apache.hadoop.hive.metastore.api.Database getDatabaseCurrent()
                                                                 throws HiveException

Get the Database object for current database

Returns:: a Database object if this database exists, null otherwise.
Throws:: HiveException

loadPartition
```
public Partition loadPartition(org.apache.hadoop.fs.Path loadPath,
                               Table tbl,
                               Map<String,String> partSpec,
                               LoadTableDesc.LoadFileType loadFileType,
                               boolean inheritTableSpecs,
                               boolean isSkewedStoreAsSubdir,
                               boolean isSrcLocal,
                               boolean isAcidIUDoperation,
                               boolean hasFollowingStatsTask,
                               Long writeId,
                               int stmtId,
                               boolean isInsertOverwrite)
                        throws HiveException
```
Load a directory into a Hive Table Partition - Alters existing content of the partition with the contents of loadPath. - If the partition does not exist - one is created - files in loadPath are moved into Hive. But the directory itself is not removed.

Parameters:

loadPath - Directory containing files to load into Table

tbl - name of table to be loaded.

partSpec - defines which partition needs to be loaded

loadFileType - if REPLACE_ALL - replace files in the table, otherwise add files to table (KEEP_EXISTING, OVERWRITE_EXISTING)

inheritTableSpecs - if true, on [re]creating the partition, take the location/inputformat/outputformat/serde details from table spec

isSrcLocal - If the source directory is LOCAL

isAcidIUDoperation - true if this is an ACID operation Insert/Update/Delete operation

hasFollowingStatsTask - true if there is a following task which updates the stats, so, this method need not update.

writeId - write ID allocated for the current load operation

stmtId - statement ID of the current load statement

isInsertOverwrite -

Returns:

Partition object being loaded with data

Throws:

HiveException

loadDynamicPartitions

public Map<Map<String,String>,Partition> loadDynamicPartitions(org.apache.hadoop.fs.Path loadPath,
                                                               String tableName,
                                                               Map<String,String> partSpec,
                                                               LoadTableDesc.LoadFileType loadFileType,
                                                               int numDP,
                                                               int numLB,
                                                               boolean isAcid,
                                                               long writeId,
                                                               int stmtId,
                                                               boolean hasFollowingStatsTask,
                                                               AcidUtils.Operation operation,
                                                               boolean isInsertOverwrite)
                                                        throws HiveException

Given a source directory name of the load path, load all dynamically generated partitions into the specified table and return a list of strings that represent the dynamic partition paths.

Parameters:: loadPath -; tableName -; partSpec -; loadFileType -; numDP - number of dynamic partitions; isAcid - true if this is an ACID operation; writeId - writeId, can be 0 unless isAcid == true
Returns:: partition map details (PartitionSpec and Partition)
Throws:: HiveException

loadTable
```
public void loadTable(org.apache.hadoop.fs.Path loadPath,
                      String tableName,
                      LoadTableDesc.LoadFileType loadFileType,
                      boolean isSrcLocal,
                      boolean isSkewedStoreAsSubdir,
                      boolean isAcidIUDoperation,
                      boolean hasFollowingStatsTask,
                      Long writeId,
                      int stmtId,
                      boolean isInsertOverwrite)
               throws HiveException
```
Load a directory into a Hive Table. - Alters existing content of table with the contents of loadPath. - If table does not exist - an exception is thrown - files in loadPath are moved into Hive. But the directory itself is not removed.

Parameters:

loadPath - Directory containing files to load into Table

tableName - name of table to be loaded.

loadFileType - if REPLACE_ALL - replace files in the table, otherwise add files to table (KEEP_EXISTING, OVERWRITE_EXISTING)

isSrcLocal - If the source directory is LOCAL

isSkewedStoreAsSubdir - if list bucketing enabled

hasFollowingStatsTask - if there is any following stats task

isAcidIUDoperation - true if this is an ACID based Insert [overwrite]/update/delete

writeId - write ID allocated for the current load operation

stmtId - statement ID of the current load statement

Throws:

HiveException

createPartition
```
public Partition createPartition(Table tbl,
                                 Map<String,String> partSpec)
                          throws HiveException
```
Creates a partition.

Parameters:

tbl - table for which partition needs to be created

partSpec - partition keys and their values

Returns:

created partition object

Throws:

HiveException - if table doesn't exist or partition already exists

createPartitions

public List<Partition> createPartitions(AddPartitionDesc addPartitionDesc)
                                 throws HiveException

Throws:: HiveException

convertAddSpecToMetaPartition

public static org.apache.hadoop.hive.metastore.api.Partition convertAddSpecToMetaPartition(Table tbl,
                                                                                           AddPartitionDesc.OnePartitionDesc addSpec,
                                                                                           HiveConf conf)
                                                                                    throws HiveException

Throws:: HiveException

getPartition

public Partition getPartition(Table tbl,
                              Map<String,String> partSpec,
                              boolean forceCreate)
                       throws HiveException

Throws:: HiveException

getPartition
```
public Partition getPartition(Table tbl,
                              Map<String,String> partSpec,
                              boolean forceCreate,
                              String partPath,
                              boolean inheritTableSpecs)
                       throws HiveException
```
Returns partition metadata

Parameters:

tbl - the partition's table

partSpec - partition keys and values

forceCreate - if this is true and partition doesn't exist then a partition is created

partPath - the path where the partition data is located

inheritTableSpecs - whether to copy over the table specs for if/of/serde

Returns:

result partition object or null if there is no partition

Throws:

HiveException

dropPartition

public boolean dropPartition(String tblName,
                             List<String> part_vals,
                             boolean deleteData)
                      throws HiveException

Throws:: HiveException

dropPartition

public boolean dropPartition(String db_name,
                             String tbl_name,
                             List<String> part_vals,
                             boolean deleteData)
                      throws HiveException

Throws:: HiveException

dropPartition

public boolean dropPartition(String dbName,
                             String tableName,
                             List<String> partVals,
                             PartitionDropOptions options)
                      throws HiveException

Throws:: HiveException

dropPartitions
```
public List<Partition> dropPartitions(Table table,
                                      List<String> partDirNames,
                                      boolean deleteData,
                                      boolean ifExists)
                               throws HiveException
```
drop the partitions specified as directory names associated with the table.

Parameters:

table - object for which partition is needed

partDirNames - partition directories that need to be dropped

deleteData - whether data should be deleted from file system

ifExists - check for existence before attempting delete

Returns:

list of partition objects that were deleted

Throws:

HiveException

dropPartitions

public List<Partition> dropPartitions(String tblName,
                                      List<DropTableDesc.PartSpec> partSpecs,
                                      boolean deleteData,
                                      boolean ifExists)
                               throws HiveException

Throws:: HiveException

dropPartitions

public List<Partition> dropPartitions(String dbName,
                                      String tblName,
                                      List<DropTableDesc.PartSpec> partSpecs,
                                      boolean deleteData,
                                      boolean ifExists)
                               throws HiveException

Throws:: HiveException

dropPartitions

public List<Partition> dropPartitions(String tblName,
                                      List<DropTableDesc.PartSpec> partSpecs,
                                      PartitionDropOptions dropOptions)
                               throws HiveException

Throws:: HiveException

dropPartitions

public List<Partition> dropPartitions(String dbName,
                                      String tblName,
                                      List<DropTableDesc.PartSpec> partSpecs,
                                      PartitionDropOptions dropOptions)
                               throws HiveException

Throws:: HiveException

getPartitionNames

public List<String> getPartitionNames(String tblName,
                                      short max)
                               throws HiveException

Throws:: HiveException

getPartitionNames

public List<String> getPartitionNames(String dbName,
                                      String tblName,
                                      short max)
                               throws HiveException

Throws:: HiveException

getPartitionNames

public List<String> getPartitionNames(String dbName,
                                      String tblName,
                                      Map<String,String> partSpec,
                                      short max)
                               throws HiveException

Throws:: HiveException

getPartitions
```
public List<Partition> getPartitions(Table tbl)
                              throws HiveException
```
get all the partitions that the table has

Parameters:

tbl - object for which partition is needed

Returns:

list of partition objects

Throws:

HiveException

getAllPartitionsOf
```
public Set<Partition> getAllPartitionsOf(Table tbl)
                                  throws HiveException
```
Get all the partitions; unlike getPartitions(Table), does not include auth.

Parameters:

tbl - table for which partitions are needed

Returns:

list of partition objects

Throws:

HiveException

getPartitions
```
public List<Partition> getPartitions(Table tbl,
                                     Map<String,String> partialPartSpec,
                                     short limit)
                              throws HiveException
```
get all the partitions of the table that matches the given partial specification. partition columns whose value is can be anything should be an empty string.

Parameters:

tbl - object for which partition is needed. Must be partitioned.

limit - number of partitions to return

Returns:

list of partition objects

Throws:

HiveException

getPartitions
```
public List<Partition> getPartitions(Table tbl,
                                     Map<String,String> partialPartSpec)
                              throws HiveException
```
get all the partitions of the table that matches the given partial specification. partition columns whose value is can be anything should be an empty string.

Parameters:

tbl - object for which partition is needed. Must be partitioned.

Returns:

list of partition objects

Throws:

HiveException

getPartitionsByNames
```
public List<Partition> getPartitionsByNames(Table tbl,
                                            Map<String,String> partialPartSpec)
                                     throws HiveException
```
get all the partitions of the table that matches the given partial specification. partition columns whose value is can be anything should be an empty string.

Parameters:

tbl - object for which partition is needed. Must be partitioned.

partialPartSpec - partial partition specification (some subpartitions can be empty).

Returns:

list of partition objects

Throws:

HiveException

getPartitionsByNames
```
public List<Partition> getPartitionsByNames(Table tbl,
                                            List<String> partNames)
                                     throws HiveException
```
Get all partitions of the table that matches the list of given partition names.

Parameters:

tbl - object for which partition is needed. Must be partitioned.

partNames - list of partition names

Returns:

list of partition objects

Throws:

HiveException

getPartitionsByFilter

public List<Partition> getPartitionsByFilter(Table tbl,
                                             String filter)
                                      throws HiveException,
                                             org.apache.hadoop.hive.metastore.api.MetaException,
                                             org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                             org.apache.thrift.TException

Get a list of Partitions by filter.

Parameters:: tbl - The table containing the partitions.; filter - A string represent partition predicates.
Returns:: a list of partitions satisfying the partition predicates.
Throws:: HiveException; org.apache.hadoop.hive.metastore.api.MetaException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException; org.apache.thrift.TException

getPartitionsByExpr

public boolean getPartitionsByExpr(Table tbl,
                                   ExprNodeGenericFuncDesc expr,
                                   HiveConf conf,
                                   List<Partition> result)
                            throws HiveException,
                                   org.apache.thrift.TException

Get a list of Partitions by expr.

Parameters:: tbl - The table containing the partitions.; expr - A serialized expression for partition predicates.; conf - Hive config.; result - the resulting list of partitions
Returns:: whether the resulting list contains partitions which may or may not match the expr
Throws:: HiveException; org.apache.thrift.TException

getNumPartitionsByFilter

public int getNumPartitionsByFilter(Table tbl,
                                    String filter)
                             throws HiveException,
                                    org.apache.hadoop.hive.metastore.api.MetaException,
                                    org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                    org.apache.thrift.TException

Get a number of Partitions by filter.

Parameters:: tbl - The table containing the partitions.; filter - A string represent partition predicates.
Returns:: the number of partitions satisfying the partition predicates.
Throws:: HiveException; org.apache.hadoop.hive.metastore.api.MetaException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException; org.apache.thrift.TException

validatePartitionNameCharacters

public void validatePartitionNameCharacters(List<String> partVals)
                                     throws HiveException

Throws:: HiveException

createRole

public void createRole(String roleName,
                       String ownerName)
                throws HiveException

Throws:: HiveException

dropRole

public void dropRole(String roleName)
              throws HiveException

Throws:: HiveException

getAllRoleNames

public List<String> getAllRoleNames()
                             throws HiveException

Get all existing role names.

Returns:: List of role names.
Throws:: HiveException

getRoleGrantInfoForPrincipal

public List<org.apache.hadoop.hive.metastore.api.RolePrincipalGrant> getRoleGrantInfoForPrincipal(String principalName,
                                                                                                  org.apache.hadoop.hive.metastore.api.PrincipalType principalType)
                                                                                           throws HiveException

Throws:: HiveException

grantRole

public boolean grantRole(String roleName,
                         String userName,
                         org.apache.hadoop.hive.metastore.api.PrincipalType principalType,
                         String grantor,
                         org.apache.hadoop.hive.metastore.api.PrincipalType grantorType,
                         boolean grantOption)
                  throws HiveException

Throws:: HiveException

revokeRole

public boolean revokeRole(String roleName,
                          String userName,
                          org.apache.hadoop.hive.metastore.api.PrincipalType principalType,
                          boolean grantOption)
                   throws HiveException

Throws:: HiveException

listRoles

public List<org.apache.hadoop.hive.metastore.api.Role> listRoles(String userName,
                                                                 org.apache.hadoop.hive.metastore.api.PrincipalType principalType)
                                                          throws HiveException

Throws:: HiveException

get_privilege_set

public org.apache.hadoop.hive.metastore.api.PrincipalPrivilegeSet get_privilege_set(org.apache.hadoop.hive.metastore.api.HiveObjectType objectType,
                                                                                    String db_name,
                                                                                    String table_name,
                                                                                    List<String> part_values,
                                                                                    String column_name,
                                                                                    String user_name,
                                                                                    List<String> group_names)
                                                                             throws HiveException

Parameters:: objectType - hive object type; db_name - database name; table_name - table name; part_values - partition values; column_name - column name; user_name - user name; group_names - group names
Returns:: the privilege set
Throws:: HiveException

showPrivilegeGrant

public List<org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege> showPrivilegeGrant(org.apache.hadoop.hive.metastore.api.HiveObjectType objectType,
                                                                                         String principalName,
                                                                                         org.apache.hadoop.hive.metastore.api.PrincipalType principalType,
                                                                                         String dbName,
                                                                                         String tableName,
                                                                                         List<String> partValues,
                                                                                         String columnName)
                                                                                  throws HiveException

Parameters:: objectType - hive object type; principalName -; principalType -; dbName -; tableName -; partValues -; columnName -
Returns:: list of privileges
Throws:: HiveException

clearDestForSubDirSrc

public static void clearDestForSubDirSrc(HiveConf conf,
                                         org.apache.hadoop.fs.Path dest,
                                         org.apache.hadoop.fs.Path src,
                                         boolean isSrcLocal)
                                  throws IOException

Throws:: IOException

listNewFilesRecursively

public static void listNewFilesRecursively(org.apache.hadoop.fs.FileSystem destFs,
                                           org.apache.hadoop.fs.Path dest,
                                           List<org.apache.hadoop.fs.Path> newFiles)
                                    throws HiveException

Throws:: HiveException

recycleDirToCmPath
```
public void recycleDirToCmPath(org.apache.hadoop.fs.Path dataPath,
                               boolean isPurge)
                        throws HiveException
```
Recycles the files recursively from the input path to the cmroot directory either by copying or moving it.

Parameters:

dataPath - Path of the data files to be recycled to cmroot

isPurge - When set to true files which needs to be recycled are not moved to Trash

Throws:

HiveException

moveFile

public static boolean moveFile(HiveConf conf,
                               org.apache.hadoop.fs.Path srcf,
                               org.apache.hadoop.fs.Path destf,
                               boolean replace,
                               boolean isSrcLocal,
                               boolean isManaged)
                        throws HiveException

Throws:: HiveException

copyFiles

protected static void copyFiles(HiveConf conf,
                                org.apache.hadoop.fs.Path srcf,
                                org.apache.hadoop.fs.Path destf,
                                org.apache.hadoop.fs.FileSystem fs,
                                boolean isSrcLocal,
                                boolean isAcidIUD,
                                boolean isOverwrite,
                                List<org.apache.hadoop.fs.Path> newFiles,
                                boolean isBucketed,
                                boolean isFullAcidTable,
                                boolean isManaged)
                         throws HiveException

Copy files. This handles building the mapping for buckets and such between the source and destination

Parameters:: conf - Configuration object; srcf - source directory, if bucketed should contain bucket files; destf - directory to move files into; fs - Filesystem; isSrcLocal - true if source is on local file system; isAcidIUD - true if this is an ACID based Insert/Update/Delete; isOverwrite - if true, then overwrite if destination file exist, else add a duplicate copy; newFiles - if this is non-null, a list of files that were created as a result of this move will be returned.; isManaged - if table is managed.
Throws:: HiveException

moveAcidFiles

public static void moveAcidFiles(org.apache.hadoop.fs.FileSystem fs,
                                 org.apache.hadoop.fs.FileStatus[] stats,
                                 org.apache.hadoop.fs.Path dst,
                                 List<org.apache.hadoop.fs.Path> newFiles)
                          throws HiveException

Throws:: HiveException

replaceFiles
```
protected void replaceFiles(org.apache.hadoop.fs.Path tablePath,
                            org.apache.hadoop.fs.Path srcf,
                            org.apache.hadoop.fs.Path destf,
                            org.apache.hadoop.fs.Path oldPath,
                            HiveConf conf,
                            boolean isSrcLocal,
                            boolean purge,
                            List<org.apache.hadoop.fs.Path> newFiles,
                            org.apache.hadoop.fs.PathFilter deletePathFilter,
                            boolean isNeedRecycle,
                            boolean isManaged)
                     throws HiveException
```
Replaces files in the partition with new data set specified by srcf. Works by renaming directory of srcf to the destination file. srcf, destf, and tmppath should resident in the same DFS, but the oldPath can be in a different DFS.

Parameters:

tablePath - path of the table. Used to identify permission inheritance.

srcf - Source directory to be renamed to tmppath. It should be a leaf directory where the final data files reside. However it could potentially contain subdirectories as well.

destf - The directory where the final data needs to go

oldPath - The directory where the old data location, need to be cleaned up. Most of time, will be the same as destf, unless its across FileSystem boundaries.

purge - When set to true files which needs to be deleted are not moved to Trash

isSrcLocal - If the source directory is LOCAL

newFiles - Output the list of new files replaced in the destination path

isManaged - If the table is managed.

Throws:

HiveException

trashFiles

public static boolean trashFiles(org.apache.hadoop.fs.FileSystem fs,
                                 org.apache.hadoop.fs.FileStatus[] statuses,
                                 org.apache.hadoop.conf.Configuration conf,
                                 boolean purge)
                          throws IOException

Trashes or deletes all files under a directory. Leaves the directory as is.

Parameters:: fs - FileSystem to use; statuses - fileStatuses of files to be deleted; conf - hive configuration
Returns:: true if deletion successful
Throws:: IOException

isHadoop1
```
public static boolean isHadoop1()
```

exchangeTablePartitions

public List<Partition> exchangeTablePartitions(Map<String,String> partitionSpecs,
                                               String sourceDb,
                                               String sourceTable,
                                               String destDb,
                                               String destinationTableName)
                                        throws HiveException

Throws:: HiveException

getSynchronizedMSC

@InterfaceAudience.LimitedPrivate(value="Hive")
 @InterfaceStability.Unstable
public SynchronizedMetaStoreClient getSynchronizedMSC()
                                                                                                                             throws org.apache.hadoop.hive.metastore.api.MetaException

Returns:: synchronized metastore client
Throws:: org.apache.hadoop.hive.metastore.api.MetaException

getMSC

@InterfaceAudience.LimitedPrivate(value="Hive")
 @InterfaceStability.Unstable
public IMetaStoreClient getMSC()
                                                                                                      throws org.apache.hadoop.hive.metastore.api.MetaException

Returns:: the metastore client for the current thread
Throws:: org.apache.hadoop.hive.metastore.api.MetaException

getMSC

@InterfaceAudience.LimitedPrivate(value="Hive")
 @InterfaceStability.Unstable
public IMetaStoreClient getMSC(boolean allowEmbedded,
                                                                                                             boolean forceCreate)
                                                                                                      throws org.apache.hadoop.hive.metastore.api.MetaException

Returns:: the metastore client for the current thread
Throws:: org.apache.hadoop.hive.metastore.api.MetaException

getFieldsFromDeserializer

public static List<org.apache.hadoop.hive.metastore.api.FieldSchema> getFieldsFromDeserializer(String name,
                                                                                               Deserializer serde)
                                                                                        throws HiveException

Throws:: HiveException

setPartitionColumnStatistics

public boolean setPartitionColumnStatistics(org.apache.hadoop.hive.metastore.api.SetPartitionsStatsRequest request)
                                     throws HiveException

Throws:: HiveException

getTableColumnStatistics

public List<org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj> getTableColumnStatistics(String dbName,
                                                                                               String tableName,
                                                                                               List<String> colNames)
                                                                                        throws HiveException

Throws:: HiveException

getPartitionColumnStatistics

public Map<String,List<org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj>> getPartitionColumnStatistics(String dbName,
                                                                                                               String tableName,
                                                                                                               List<String> partNames,
                                                                                                               List<String> colNames)
                                                                                                        throws HiveException

Throws:: HiveException

getAggrColStatsFor

public org.apache.hadoop.hive.metastore.api.AggrStats getAggrColStatsFor(String dbName,
                                                                         String tblName,
                                                                         List<String> colNames,
                                                                         List<String> partName)

deleteTableColumnStatistics

public boolean deleteTableColumnStatistics(String dbName,
                                           String tableName,
                                           String colName)
                                    throws HiveException

Throws:: HiveException

deletePartitionColumnStatistics

public boolean deletePartitionColumnStatistics(String dbName,
                                               String tableName,
                                               String partName,
                                               String colName)
                                        throws HiveException

Throws:: HiveException

newTable

public Table newTable(String tableName)
               throws HiveException

Throws:: HiveException

getDelegationToken

public String getDelegationToken(String owner,
                                 String renewer)
                          throws HiveException

Throws:: HiveException

cancelDelegationToken

public void cancelDelegationToken(String tokenStrForm)
                           throws HiveException

Throws:: HiveException

compact

@Deprecated
public void compact(String dbname,
                                String tableName,
                                String partName,
                                String compactType,
                                Map<String,String> tblproperties)
                         throws HiveException

Deprecated. use compact2(String, String, String, String, Map)

Throws:: HiveException

compact2

public org.apache.hadoop.hive.metastore.api.CompactionResponse compact2(String dbname,
                                                                        String tableName,
                                                                        String partName,
                                                                        String compactType,
                                                                        Map<String,String> tblproperties)
                                                                 throws HiveException

Enqueue a compaction request. Only 1 compaction for a given resource (db/table/partSpec) can be scheduled/running at any given time.

Parameters:: dbname - name of the database, if null default will be used.; tableName - name of the table, cannot be null; partName - name of the partition, if null table will be compacted (valid only for non-partitioned tables).; compactType - major or minor; tblproperties - the list of tblproperties to overwrite for this compaction
Returns:: id of new request or id already existing request for specified resource
Throws:: HiveException

showCompactions

public org.apache.hadoop.hive.metastore.api.ShowCompactResponse showCompactions()
                                                                         throws HiveException

Throws:: HiveException

showTransactions

public org.apache.hadoop.hive.metastore.api.GetOpenTxnsInfoResponse showTransactions()
                                                                              throws HiveException

Throws:: HiveException

abortTransactions

public void abortTransactions(List<Long> txnids)
                       throws HiveException

Throws:: HiveException

createFunction

public void createFunction(org.apache.hadoop.hive.metastore.api.Function func)
                    throws HiveException

Throws:: HiveException

alterFunction

public void alterFunction(String dbName,
                          String funcName,
                          org.apache.hadoop.hive.metastore.api.Function newFunction)
                   throws HiveException

Throws:: HiveException

dropFunction

public void dropFunction(String dbName,
                         String funcName)
                  throws HiveException

Throws:: HiveException

getFunction

public org.apache.hadoop.hive.metastore.api.Function getFunction(String dbName,
                                                                 String funcName)
                                                          throws HiveException

Throws:: HiveException

getAllFunctions

public List<org.apache.hadoop.hive.metastore.api.Function> getAllFunctions()
                                                                    throws HiveException

Throws:: HiveException

getFunctions

public List<String> getFunctions(String dbName,
                                 String pattern)
                          throws HiveException

Throws:: HiveException

setMetaConf

public void setMetaConf(String propName,
                        String propValue)
                 throws HiveException

Throws:: HiveException

getMetaConf

public String getMetaConf(String propName)
                   throws HiveException

Throws:: HiveException

clearMetaCallTiming
```
public void clearMetaCallTiming()
```

dumpAndClearMetaCallTiming

public com.google.common.collect.ImmutableMap<String,Long> dumpAndClearMetaCallTiming(String phase)

getFileMetadata

public Iterable<Map.Entry<Long,ByteBuffer>> getFileMetadata(List<Long> fileIds)
                                                     throws HiveException

Throws:: HiveException

getFileMetadataByExpr

public Iterable<Map.Entry<Long,org.apache.hadoop.hive.metastore.api.MetadataPpdResult>> getFileMetadataByExpr(List<Long> fileIds,
                                                                                                              ByteBuffer sarg,
                                                                                                              boolean doGetFooters)
                                                                                                       throws HiveException

Throws:: HiveException

clearFileMetadata

public void clearFileMetadata(List<Long> fileIds)
                       throws HiveException

Throws:: HiveException

putFileMetadata

public void putFileMetadata(List<Long> fileIds,
                            List<ByteBuffer> metadata)
                     throws HiveException

Throws:: HiveException

cacheFileMetadata

public void cacheFileMetadata(String dbName,
                              String tableName,
                              String partName,
                              boolean allParts)
                       throws HiveException

Throws:: HiveException

dropConstraint

public void dropConstraint(String dbName,
                           String tableName,
                           String constraintName)
                    throws HiveException,
                           org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:: HiveException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException

getPrimaryKeyList

public List<org.apache.hadoop.hive.metastore.api.SQLPrimaryKey> getPrimaryKeyList(String dbName,
                                                                                  String tblName)
                                                                           throws HiveException,
                                                                                  org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:: HiveException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException

getForeignKeyList

public List<org.apache.hadoop.hive.metastore.api.SQLForeignKey> getForeignKeyList(String dbName,
                                                                                  String tblName)
                                                                           throws HiveException,
                                                                                  org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:: HiveException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException

getUniqueConstraintList

public List<org.apache.hadoop.hive.metastore.api.SQLUniqueConstraint> getUniqueConstraintList(String dbName,
                                                                                              String tblName)
                                                                                       throws HiveException,
                                                                                              org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:: HiveException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException

getNotNullConstraintList

public List<org.apache.hadoop.hive.metastore.api.SQLNotNullConstraint> getNotNullConstraintList(String dbName,
                                                                                                String tblName)
                                                                                         throws HiveException,
                                                                                                org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:: HiveException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException

getDefaultConstraintList

public List<org.apache.hadoop.hive.metastore.api.SQLDefaultConstraint> getDefaultConstraintList(String dbName,
                                                                                                String tblName)
                                                                                         throws HiveException,
                                                                                                org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:: HiveException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException

getCheckConstraintList

public List<org.apache.hadoop.hive.metastore.api.SQLCheckConstraint> getCheckConstraintList(String dbName,
                                                                                            String tblName)
                                                                                     throws HiveException,
                                                                                            org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:: HiveException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException

getPrimaryKeys

public PrimaryKeyInfo getPrimaryKeys(String dbName,
                                     String tblName)
                              throws HiveException

Get all primary key columns associated with the table.

Parameters:: dbName - Database Name; tblName - Table Name
Returns:: Primary Key associated with the table.
Throws:: HiveException

getReliablePrimaryKeys

public PrimaryKeyInfo getReliablePrimaryKeys(String dbName,
                                             String tblName)
                                      throws HiveException

Get primary key columns associated with the table that are available for optimization.

Parameters:: dbName - Database Name; tblName - Table Name
Returns:: Primary Key associated with the table.
Throws:: HiveException

getForeignKeys

public ForeignKeyInfo getForeignKeys(String dbName,
                                     String tblName)
                              throws HiveException

Get all foreign keys associated with the table.

Parameters:: dbName - Database Name; tblName - Table Name
Returns:: Foreign keys associated with the table.
Throws:: HiveException

getReliableForeignKeys

public ForeignKeyInfo getReliableForeignKeys(String dbName,
                                             String tblName)
                                      throws HiveException

Get foreign keys associated with the table that are available for optimization.

Parameters:: dbName - Database Name; tblName - Table Name
Returns:: Foreign keys associated with the table.
Throws:: HiveException

getUniqueConstraints

public UniqueConstraint getUniqueConstraints(String dbName,
                                             String tblName)
                                      throws HiveException

Get all unique constraints associated with the table.

Parameters:: dbName - Database Name; tblName - Table Name
Returns:: Unique constraints associated with the table.
Throws:: HiveException

getReliableUniqueConstraints

public UniqueConstraint getReliableUniqueConstraints(String dbName,
                                                     String tblName)
                                              throws HiveException

Get unique constraints associated with the table that are available for optimization.

Parameters:: dbName - Database Name; tblName - Table Name
Returns:: Unique constraints associated with the table.
Throws:: HiveException

getNotNullConstraints

public NotNullConstraint getNotNullConstraints(String dbName,
                                               String tblName)
                                        throws HiveException

Get all not null constraints associated with the table.

Parameters:: dbName - Database Name; tblName - Table Name
Returns:: Not null constraints associated with the table.
Throws:: HiveException

getReliableNotNullConstraints

public NotNullConstraint getReliableNotNullConstraints(String dbName,
                                                       String tblName)
                                                throws HiveException

Get not null constraints associated with the table that are available for optimization.

Parameters:: dbName - Database Name; tblName - Table Name
Returns:: Not null constraints associated with the table.
Throws:: HiveException

getEnabledNotNullConstraints

public NotNullConstraint getEnabledNotNullConstraints(String dbName,
                                                      String tblName)
                                               throws HiveException

Get not null constraints associated with the table that are enabled/enforced.

Parameters:: dbName - Database Name; tblName - Table Name
Returns:: Not null constraints associated with the table.
Throws:: HiveException

getEnabledCheckConstraints

public CheckConstraint getEnabledCheckConstraints(String dbName,
                                                  String tblName)
                                           throws HiveException

Get CHECK constraints associated with the table that are enabled

Parameters:: dbName - Database Name; tblName - Table Name
Returns:: CHECK constraints associated with the table.
Throws:: HiveException

getEnabledDefaultConstraints

public DefaultConstraint getEnabledDefaultConstraints(String dbName,
                                                      String tblName)
                                               throws HiveException

Get Default constraints associated with the table that are enabled

Parameters:: dbName - Database Name; tblName - Table Name
Returns:: Default constraints associated with the table.
Throws:: HiveException

getDefaultConstraints

public DefaultConstraint getDefaultConstraints(String dbName,
                                               String tblName)
                                        throws HiveException

Throws:: HiveException

getCheckConstraints

public CheckConstraint getCheckConstraints(String dbName,
                                           String tblName)
                                    throws HiveException

Throws:: HiveException

addPrimaryKey

public void addPrimaryKey(List<org.apache.hadoop.hive.metastore.api.SQLPrimaryKey> primaryKeyCols)
                   throws HiveException,
                          org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:: HiveException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException

addForeignKey

public void addForeignKey(List<org.apache.hadoop.hive.metastore.api.SQLForeignKey> foreignKeyCols)
                   throws HiveException,
                          org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:: HiveException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException

addUniqueConstraint

public void addUniqueConstraint(List<org.apache.hadoop.hive.metastore.api.SQLUniqueConstraint> uniqueConstraintCols)
                         throws HiveException,
                                org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:: HiveException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException

addNotNullConstraint

public void addNotNullConstraint(List<org.apache.hadoop.hive.metastore.api.SQLNotNullConstraint> notNullConstraintCols)
                          throws HiveException,
                                 org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:: HiveException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException

addDefaultConstraint

public void addDefaultConstraint(List<org.apache.hadoop.hive.metastore.api.SQLDefaultConstraint> defaultConstraints)
                          throws HiveException,
                                 org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:: HiveException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException

addCheckConstraint

public void addCheckConstraint(List<org.apache.hadoop.hive.metastore.api.SQLCheckConstraint> checkConstraints)
                        throws HiveException,
                               org.apache.hadoop.hive.metastore.api.NoSuchObjectException

Throws:: HiveException; org.apache.hadoop.hive.metastore.api.NoSuchObjectException

createResourcePlan

public void createResourcePlan(org.apache.hadoop.hive.metastore.api.WMResourcePlan resourcePlan,
                               String copyFromName)
                        throws HiveException

Throws:: HiveException

getResourcePlan

public org.apache.hadoop.hive.metastore.api.WMFullResourcePlan getResourcePlan(String rpName)
                                                                        throws HiveException

Throws:: HiveException

getAllResourcePlans

public List<org.apache.hadoop.hive.metastore.api.WMResourcePlan> getAllResourcePlans()
                                                                              throws HiveException

Throws:: HiveException

dropResourcePlan

public void dropResourcePlan(String rpName)
                      throws HiveException

Throws:: HiveException

alterResourcePlan

public org.apache.hadoop.hive.metastore.api.WMFullResourcePlan alterResourcePlan(String rpName,
                                                                                 org.apache.hadoop.hive.metastore.api.WMNullableResourcePlan resourcePlan,
                                                                                 boolean canActivateDisabled,
                                                                                 boolean isForceDeactivate,
                                                                                 boolean isReplace)
                                                                          throws HiveException

Throws:: HiveException

getActiveResourcePlan

public org.apache.hadoop.hive.metastore.api.WMFullResourcePlan getActiveResourcePlan()
                                                                              throws HiveException

Throws:: HiveException

validateResourcePlan

public org.apache.hadoop.hive.metastore.api.WMValidateResourcePlanResponse validateResourcePlan(String rpName)
                                                                                         throws HiveException

Throws:: HiveException

createWMTrigger

public void createWMTrigger(org.apache.hadoop.hive.metastore.api.WMTrigger trigger)
                     throws HiveException

Throws:: HiveException

alterWMTrigger

public void alterWMTrigger(org.apache.hadoop.hive.metastore.api.WMTrigger trigger)
                    throws HiveException

Throws:: HiveException

dropWMTrigger

public void dropWMTrigger(String rpName,
                          String triggerName)
                   throws HiveException

Throws:: HiveException

createWMPool

public void createWMPool(org.apache.hadoop.hive.metastore.api.WMPool pool)
                  throws HiveException

Throws:: HiveException

alterWMPool

public void alterWMPool(org.apache.hadoop.hive.metastore.api.WMNullablePool pool,
                        String poolPath)
                 throws HiveException

Throws:: HiveException

dropWMPool

public void dropWMPool(String resourcePlanName,
                       String poolPath)
                throws HiveException

Throws:: HiveException

createOrUpdateWMMapping

public void createOrUpdateWMMapping(org.apache.hadoop.hive.metastore.api.WMMapping mapping,
                                    boolean isUpdate)
                             throws HiveException

Throws:: HiveException

dropWMMapping

public void dropWMMapping(org.apache.hadoop.hive.metastore.api.WMMapping mapping)
                   throws HiveException

Throws:: HiveException

createOrDropTriggerToPoolMapping

public void createOrDropTriggerToPoolMapping(String resourcePlanName,
                                             String triggerName,
                                             String poolPath,
                                             boolean shouldDrop)
                                      throws HiveException

Throws:: HiveException

getStorageHandlerInfo

@Nullable
public StorageHandlerInfo getStorageHandlerInfo(Table table)
                                                   throws HiveException

Throws:: HiveException

Class Hive

Nested Class Summary

Method Summary

Methods inherited from class java.lang.Object

Method Detail

reloadFunctions

get

get

getWithFastCheck

getWithFastCheck

get

get

get

set

closeCurrent

createDatabase

createDatabase

dropDatabase

dropDatabase

dropDatabase

createTable

createTable

createTable

alterTable

alterTable

alterTable

alterTable

updateCreationMetadata

alterPartition

alterPartition

alterPartitions

renamePartition

alterDatabase

createTable

createTable

createTable

getFieldsFromDeserializerForMsStorage

dropTable

dropTable

dropTable

dropTable

dropTable

truncateTable

getConf

getTable

getTable

getTable

getTable

getAllTables

getAllTables

getAllTableObjects

getAllMaterializedViews

getAllMaterializedViewObjects

getTablesByPattern

getTablesByPattern

getTablesForDb

getTablesByType

getAllValidMaterializedViews

getValidMaterializedView

getAllDatabases

getDatabasesByPattern

grantPrivileges

revokePrivileges

databaseExists

getDatabase

getDatabase

getDatabaseCurrent

loadPartition

loadDynamicPartitions

loadTable

createPartition

createPartitions

convertAddSpecToMetaPartition

getPartition

getPartition

dropPartition

dropPartition

dropPartition

dropPartitions

dropPartitions