org.apache.flink.table.catalog.hive.client

类 HiveMetastoreClientWrapper

java.lang.Object

org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper

所有已实现的接口:

AutoCloseable

@Internal
public class HiveMetastoreClientWrapper
extends Object
implements AutoCloseable

Wrapper class for Hive Metastore Client, which embeds a HiveShim layer to handle different Hive versions. Methods provided mostly conforms to IMetaStoreClient interfaces except those that require shims.

构造器概要

构造器

构造器和说明
HiveMetastoreClientWrapper(org.apache.hadoop.hive.conf.HiveConf hiveConf, String hiveVersion)

方法概要

限定符和类型	方法和说明
org.apache.hadoop.hive.metastore.api.Partition	add_partition(org.apache.hadoop.hive.metastore.api.Partition partition)
int	add_partitions(List<org.apache.hadoop.hive.metastore.api.Partition> partitionList)
void	alter_partition(String databaseName, String tableName, org.apache.hadoop.hive.metastore.api.Partition partition)
void	alter_table(String databaseName, String tableName, org.apache.hadoop.hive.metastore.api.Table table)
void	alterDatabase(String name, org.apache.hadoop.hive.metastore.api.Database database)
void	alterFunction(String databaseName, String functionName, org.apache.hadoop.hive.metastore.api.Function function)
void	close()
void	createDatabase(org.apache.hadoop.hive.metastore.api.Database database)
void	createFunction(org.apache.hadoop.hive.metastore.api.Function function)
void	createTable(org.apache.hadoop.hive.metastore.api.Table table)
void	dropDatabase(String name, boolean deleteData, boolean ignoreIfNotExists)
void	dropDatabase(String name, boolean deleteData, boolean ignoreIfNotExists, boolean cascade)
void	dropFunction(String databaseName, String functionName)
boolean	dropPartition(String databaseName, String tableName, List<String> partitionValues, boolean deleteData)
void	dropTable(String databaseName, String tableName)
void	dropTable(String dbName, String tableName, boolean deleteData, boolean ignoreUnknownTable)
List<String>	getAllDatabases()
List<String>	getAllTables(String databaseName)
org.apache.hadoop.hive.metastore.api.Database	getDatabase(String name)
List<String>	getDatabases(String pattern)
org.apache.hadoop.hive.metastore.api.Function	getFunction(String databaseName, String functionName)
List<String>	getFunctions(String databaseName, String pattern)
Set<String>	getNotNullColumns(org.apache.hadoop.conf.Configuration conf, String dbName, String tableName)
org.apache.hadoop.hive.metastore.api.Partition	getPartition(String databaseName, String tableName, List<String> list)
Map<String,List<org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj>>	getPartitionColumnStatistics(String dbName, String tableName, List<String> partNames, List<String> colNames)
Optional<org.apache.flink.table.api.constraints.UniqueConstraint>	getPrimaryKey(String dbName, String tableName, byte trait)
org.apache.hadoop.hive.metastore.api.Table	getTable(String databaseName, String tableName)
List<org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj>	getTableColumnStatistics(String databaseName, String tableName, List<String> columnNames)
List<String>	getViews(String databaseName)
List<String>	listPartitionNames(String databaseName, String tableName, List<String> partitionValues, short maxPartitions)
List<String>	listPartitionNames(String databaseName, String tableName, short maxPartitions)
List<org.apache.hadoop.hive.metastore.api.Partition>	listPartitions(String dbName, String tblName, List<String> partVals, short max)
List<org.apache.hadoop.hive.metastore.api.Partition>	listPartitions(String dbName, String tblName, short max)
org.apache.hadoop.hive.metastore.partition.spec.PartitionSpecProxy	listPartitionSpecsByFilter(String dbName, String tblName, String filter, short max)
void	renamePartition(String databaseName, String tableName, List<String> partitionValues, org.apache.hadoop.hive.metastore.api.Partition partition)
boolean	tableExists(String databaseName, String tableName)
boolean	updatePartitionColumnStatistics(org.apache.hadoop.hive.metastore.api.ColumnStatistics columnStatistics)
boolean	updateTableColumnStatistics(org.apache.hadoop.hive.metastore.api.ColumnStatistics columnStatistics)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

HiveMetastoreClientWrapper

public HiveMetastoreClientWrapper(org.apache.hadoop.hive.conf.HiveConf hiveConf,
                                  String hiveVersion)

方法详细资料

close

public void close()

指定者:

close 在接口中 AutoCloseable

getDatabases

public List<String> getDatabases(String pattern)
                          throws org.apache.hadoop.hive.metastore.api.MetaException,
                                 org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

getAllDatabases

public List<String> getAllDatabases()
                             throws org.apache.hadoop.hive.metastore.api.MetaException,
                                    org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

getAllTables

public List<String> getAllTables(String databaseName)
                          throws org.apache.hadoop.hive.metastore.api.MetaException,
                                 org.apache.thrift.TException,
                                 org.apache.hadoop.hive.metastore.api.UnknownDBException

抛出:

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

org.apache.hadoop.hive.metastore.api.UnknownDBException

dropTable

public void dropTable(String databaseName,
                      String tableName)
               throws org.apache.hadoop.hive.metastore.api.MetaException,
                      org.apache.thrift.TException,
                      org.apache.hadoop.hive.metastore.api.NoSuchObjectException

抛出:

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

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

dropTable

public void dropTable(String dbName,
                      String tableName,
                      boolean deleteData,
                      boolean ignoreUnknownTable)
               throws org.apache.hadoop.hive.metastore.api.MetaException,
                      org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                      org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.MetaException

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

org.apache.thrift.TException

tableExists

public boolean tableExists(String databaseName,
                           String tableName)
                    throws org.apache.hadoop.hive.metastore.api.MetaException,
                           org.apache.thrift.TException,
                           org.apache.hadoop.hive.metastore.api.UnknownDBException

抛出:

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

org.apache.hadoop.hive.metastore.api.UnknownDBException

getDatabase

public org.apache.hadoop.hive.metastore.api.Database getDatabase(String name)
                                                          throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                                 org.apache.hadoop.hive.metastore.api.MetaException,
                                                                 org.apache.thrift.TException

抛出:

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

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

getTable

public org.apache.hadoop.hive.metastore.api.Table getTable(String databaseName,
                                                           String tableName)
                                                    throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                           org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                           org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.MetaException

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

org.apache.thrift.TException

add_partition

public org.apache.hadoop.hive.metastore.api.Partition add_partition(org.apache.hadoop.hive.metastore.api.Partition partition)
                                                             throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                                                    org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                                                                    org.apache.hadoop.hive.metastore.api.MetaException,
                                                                    org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.InvalidObjectException

org.apache.hadoop.hive.metastore.api.AlreadyExistsException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

add_partitions

public int add_partitions(List<org.apache.hadoop.hive.metastore.api.Partition> partitionList)
                   throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                          org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                          org.apache.hadoop.hive.metastore.api.MetaException,
                          org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.InvalidObjectException

org.apache.hadoop.hive.metastore.api.AlreadyExistsException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

getPartition

public org.apache.hadoop.hive.metastore.api.Partition getPartition(String databaseName,
                                                                   String tableName,
                                                                   List<String> list)
                                                            throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                                   org.apache.hadoop.hive.metastore.api.MetaException,
                                                                   org.apache.thrift.TException

抛出:

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

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

listPartitionNames

public List<String> listPartitionNames(String databaseName,
                                       String tableName,
                                       short maxPartitions)
                                throws org.apache.hadoop.hive.metastore.api.MetaException,
                                       org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

listPartitionNames

public List<String> listPartitionNames(String databaseName,
                                       String tableName,
                                       List<String> partitionValues,
                                       short maxPartitions)
                                throws org.apache.hadoop.hive.metastore.api.MetaException,
                                       org.apache.thrift.TException,
                                       org.apache.hadoop.hive.metastore.api.NoSuchObjectException

抛出:

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

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

createTable

public void createTable(org.apache.hadoop.hive.metastore.api.Table table)
                 throws org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                        org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                        org.apache.hadoop.hive.metastore.api.MetaException,
                        org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                        org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.AlreadyExistsException

org.apache.hadoop.hive.metastore.api.InvalidObjectException

org.apache.hadoop.hive.metastore.api.MetaException

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

org.apache.thrift.TException

createDatabase

public void createDatabase(org.apache.hadoop.hive.metastore.api.Database database)
                    throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                           org.apache.hadoop.hive.metastore.api.AlreadyExistsException,
                           org.apache.hadoop.hive.metastore.api.MetaException,
                           org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.InvalidObjectException

org.apache.hadoop.hive.metastore.api.AlreadyExistsException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

dropDatabase

public void dropDatabase(String name,
                         boolean deleteData,
                         boolean ignoreIfNotExists)
                  throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                         org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                         org.apache.hadoop.hive.metastore.api.MetaException,
                         org.apache.thrift.TException

抛出:

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

org.apache.hadoop.hive.metastore.api.InvalidOperationException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

dropDatabase

public void dropDatabase(String name,
                         boolean deleteData,
                         boolean ignoreIfNotExists,
                         boolean cascade)
                  throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                         org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                         org.apache.hadoop.hive.metastore.api.MetaException,
                         org.apache.thrift.TException

抛出:

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

org.apache.hadoop.hive.metastore.api.InvalidOperationException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

alterDatabase

public void alterDatabase(String name,
                          org.apache.hadoop.hive.metastore.api.Database database)
                   throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                          org.apache.hadoop.hive.metastore.api.MetaException,
                          org.apache.thrift.TException

抛出:

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

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

dropPartition

public boolean dropPartition(String databaseName,
                             String tableName,
                             List<String> partitionValues,
                             boolean deleteData)
                      throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                             org.apache.hadoop.hive.metastore.api.MetaException,
                             org.apache.thrift.TException

抛出:

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

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

renamePartition

public void renamePartition(String databaseName,
                            String tableName,
                            List<String> partitionValues,
                            org.apache.hadoop.hive.metastore.api.Partition partition)
                     throws org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                            org.apache.hadoop.hive.metastore.api.MetaException,
                            org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.InvalidOperationException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

createFunction

public void createFunction(org.apache.hadoop.hive.metastore.api.Function function)
                    throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                           org.apache.hadoop.hive.metastore.api.MetaException,
                           org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.InvalidObjectException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

alterFunction

public void alterFunction(String databaseName,
                          String functionName,
                          org.apache.hadoop.hive.metastore.api.Function function)
                   throws org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                          org.apache.hadoop.hive.metastore.api.MetaException,
                          org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.InvalidObjectException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

dropFunction

public void dropFunction(String databaseName,
                         String functionName)
                  throws org.apache.hadoop.hive.metastore.api.MetaException,
                         org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                         org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                         org.apache.hadoop.hive.metastore.api.InvalidInputException,
                         org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.MetaException

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

org.apache.hadoop.hive.metastore.api.InvalidObjectException

org.apache.hadoop.hive.metastore.api.InvalidInputException

org.apache.thrift.TException

getFunctions

public List<String> getFunctions(String databaseName,
                                 String pattern)
                          throws org.apache.hadoop.hive.metastore.api.MetaException,
                                 org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

getTableColumnStatistics

public List<org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj> getTableColumnStatistics(String databaseName,
                                                                                               String tableName,
                                                                                               List<String> columnNames)
                                                                                        throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                                                                               org.apache.hadoop.hive.metastore.api.MetaException,
                                                                                               org.apache.thrift.TException

抛出:

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

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

getPartitionColumnStatistics

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

抛出:

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

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

updateTableColumnStatistics

public boolean updateTableColumnStatistics(org.apache.hadoop.hive.metastore.api.ColumnStatistics columnStatistics)
                                    throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                           org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                           org.apache.hadoop.hive.metastore.api.MetaException,
                                           org.apache.thrift.TException,
                                           org.apache.hadoop.hive.metastore.api.InvalidInputException

抛出:

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

org.apache.hadoop.hive.metastore.api.InvalidObjectException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

org.apache.hadoop.hive.metastore.api.InvalidInputException

updatePartitionColumnStatistics

public boolean updatePartitionColumnStatistics(org.apache.hadoop.hive.metastore.api.ColumnStatistics columnStatistics)
                                        throws org.apache.hadoop.hive.metastore.api.NoSuchObjectException,
                                               org.apache.hadoop.hive.metastore.api.InvalidObjectException,
                                               org.apache.hadoop.hive.metastore.api.MetaException,
                                               org.apache.thrift.TException,
                                               org.apache.hadoop.hive.metastore.api.InvalidInputException

抛出:

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

org.apache.hadoop.hive.metastore.api.InvalidObjectException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

org.apache.hadoop.hive.metastore.api.InvalidInputException

listPartitions

public List<org.apache.hadoop.hive.metastore.api.Partition> listPartitions(String dbName,
                                                                           String tblName,
                                                                           List<String> partVals,
                                                                           short max)
                                                                    throws org.apache.thrift.TException

抛出:

org.apache.thrift.TException

listPartitions

public List<org.apache.hadoop.hive.metastore.api.Partition> listPartitions(String dbName,
                                                                           String tblName,
                                                                           short max)
                                                                    throws org.apache.thrift.TException

抛出:

org.apache.thrift.TException

listPartitionSpecsByFilter

public org.apache.hadoop.hive.metastore.partition.spec.PartitionSpecProxy listPartitionSpecsByFilter(String dbName,
                                                                                                     String tblName,
                                                                                                     String filter,
                                                                                                     short max)
                                                                                              throws org.apache.thrift.TException

抛出:

org.apache.thrift.TException

getNotNullColumns

public Set<String> getNotNullColumns(org.apache.hadoop.conf.Configuration conf,
                                     String dbName,
                                     String tableName)

getPrimaryKey

public Optional<org.apache.flink.table.api.constraints.UniqueConstraint> getPrimaryKey(String dbName,
                                                                                       String tableName,
                                                                                       byte trait)

getViews

public List<String> getViews(String databaseName)
                      throws org.apache.hadoop.hive.metastore.api.UnknownDBException,
                             org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.UnknownDBException

org.apache.thrift.TException

getFunction

public org.apache.hadoop.hive.metastore.api.Function getFunction(String databaseName,
                                                                 String functionName)
                                                          throws org.apache.hadoop.hive.metastore.api.MetaException,
                                                                 org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

alter_table

public void alter_table(String databaseName,
                        String tableName,
                        org.apache.hadoop.hive.metastore.api.Table table)
                 throws org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                        org.apache.hadoop.hive.metastore.api.MetaException,
                        org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.InvalidOperationException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

alter_partition

public void alter_partition(String databaseName,
                            String tableName,
                            org.apache.hadoop.hive.metastore.api.Partition partition)
                     throws org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                            org.apache.hadoop.hive.metastore.api.MetaException,
                            org.apache.thrift.TException

抛出:

org.apache.hadoop.hive.metastore.api.InvalidOperationException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException