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

类 HiveShimV120

java.lang.Object

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

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

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

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

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

所有已实现的接口:

Serializable, HiveShim

直接已知子类:

HiveShimV121

public class HiveShimV120
extends HiveShimV111

Shim for Hive version 1.2.0.

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
HiveShimV120()

方法概要

限定符和类型	方法和说明
void	alterTable(org.apache.hadoop.hive.metastore.IMetaStoreClient client, String databaseName, String tableName, org.apache.hadoop.hive.metastore.api.Table table) Alters a Hive table.
Optional<org.apache.hadoop.hive.ql.exec.FunctionInfo>	getBuiltInFunctionInfo(String name) Get a Hive built-in function by name.
org.apache.hadoop.hive.metastore.IMetaStoreClient	getHiveMetastoreClient(org.apache.hadoop.hive.conf.HiveConf hiveConf) Create a Hive Metastore client based on the given HiveConf object.
boolean	isDateStats(org.apache.hadoop.hive.metastore.api.ColumnStatisticsData colStatsData) Whether a Hive ColumnStatisticsData is for DATE columns.
Set<String>	listBuiltInFunctions() List names of all built-in functions.
org.apache.flink.table.catalog.stats.CatalogColumnStatisticsDataDate	toFlinkDateColStats(org.apache.hadoop.hive.metastore.api.ColumnStatisticsData hiveDateColStats) Generate Flink CatalogColumnStatisticsDataDate from Hive ColumnStatisticsData for DATE columns.
org.apache.hadoop.hive.metastore.api.ColumnStatisticsData	toHiveDateColStats(org.apache.flink.table.catalog.stats.CatalogColumnStatisticsDataDate flinkDateColStats) Generate Hive ColumnStatisticsData from Flink CatalogColumnStatisticsDataDate for DATE columns.

从类继承的方法 org.apache.flink.table.catalog.hive.client.HiveShimV110

getFieldsFromDeserializer, getHiveOutputFormatClass, getHiveRecordWriter

从类继承的方法 org.apache.flink.table.catalog.hive.client.HiveShimV100

alterPartition, createUDAFParameterInfo, getDateDataTypeClass, getHiveMetaStoreUtilsClass, getMetaStoreUtilsClass, getNotNullColumns, getPrimaryKey, getTimestampDataTypeClass, getViews, hivePrimitiveToWritable, toFlinkDate, toFlinkTimestamp, toHiveDate, toHiveTimestamp

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

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

构造器详细资料

HiveShimV120

public HiveShimV120()

方法详细资料

getHiveMetastoreClient

public org.apache.hadoop.hive.metastore.IMetaStoreClient getHiveMetastoreClient(org.apache.hadoop.hive.conf.HiveConf hiveConf)

从接口复制的说明: HiveShim

Create a Hive Metastore client based on the given HiveConf object.

指定者:

getHiveMetastoreClient 在接口中 HiveShim

覆盖:

getHiveMetastoreClient 在类中 HiveShimV100

参数:

hiveConf - HiveConf instance

返回:

an IMetaStoreClient instance

alterTable

public void alterTable(org.apache.hadoop.hive.metastore.IMetaStoreClient client,
                       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

从接口复制的说明: HiveShim

Alters a Hive table.

指定者:

alterTable 在接口中 HiveShim

覆盖:

alterTable 在类中 HiveShimV100

参数:

client - the Hive metastore client

databaseName - the name of the database to which the table belongs

tableName - the name of the table to be altered

table - the new Hive table

抛出:

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

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

org.apache.thrift.TException

toHiveDateColStats

public org.apache.hadoop.hive.metastore.api.ColumnStatisticsData toHiveDateColStats(org.apache.flink.table.catalog.stats.CatalogColumnStatisticsDataDate flinkDateColStats)

从接口复制的说明: HiveShim

Generate Hive ColumnStatisticsData from Flink CatalogColumnStatisticsDataDate for DATE columns.

指定者:

toHiveDateColStats 在接口中 HiveShim

覆盖:

toHiveDateColStats 在类中 HiveShimV100

isDateStats

public boolean isDateStats(org.apache.hadoop.hive.metastore.api.ColumnStatisticsData colStatsData)

从接口复制的说明: HiveShim

Whether a Hive ColumnStatisticsData is for DATE columns.

指定者:

isDateStats 在接口中 HiveShim

覆盖:

isDateStats 在类中 HiveShimV100

toFlinkDateColStats

public org.apache.flink.table.catalog.stats.CatalogColumnStatisticsDataDate toFlinkDateColStats(org.apache.hadoop.hive.metastore.api.ColumnStatisticsData hiveDateColStats)

从接口复制的说明: HiveShim

Generate Flink CatalogColumnStatisticsDataDate from Hive ColumnStatisticsData for DATE columns.

指定者:

toFlinkDateColStats 在接口中 HiveShim

覆盖:

toFlinkDateColStats 在类中 HiveShimV100

listBuiltInFunctions

public Set<String> listBuiltInFunctions()

从接口复制的说明: HiveShim

List names of all built-in functions.

指定者:

listBuiltInFunctions 在接口中 HiveShim

覆盖:

listBuiltInFunctions 在类中 HiveShimV100

getBuiltInFunctionInfo

public Optional<org.apache.hadoop.hive.ql.exec.FunctionInfo> getBuiltInFunctionInfo(String name)

从接口复制的说明: HiveShim

Get a Hive built-in function by name.

指定者:

getBuiltInFunctionInfo 在接口中 HiveShim

覆盖:

getBuiltInFunctionInfo 在类中 HiveShimV100