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

类 HiveShimV100

java.lang.Object

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

所有已实现的接口:

Serializable, HiveShim

直接已知子类:

HiveShimV101

public class HiveShimV100
extends Object
implements HiveShim

Shim for Hive version 1.0.0.

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
HiveShimV100()

方法概要

限定符和类型	方法和说明
void	alterPartition(org.apache.hadoop.hive.metastore.IMetaStoreClient client, String databaseName, String tableName, org.apache.hadoop.hive.metastore.api.Partition partition)
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.
org.apache.hadoop.hive.ql.udf.generic.SimpleGenericUDAFParameterInfo	createUDAFParameterInfo(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector[] params, boolean isWindowing, boolean distinct, boolean allColumns) Creates SimpleGenericUDAFParameterInfo.
Optional<org.apache.hadoop.hive.ql.exec.FunctionInfo>	getBuiltInFunctionInfo(String name) Get a Hive built-in function by name.
Class<?>	getDateDataTypeClass() Hive Date data type class was changed in Hive 3.1.0.
List<org.apache.hadoop.hive.metastore.api.FieldSchema>	getFieldsFromDeserializer(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hive.metastore.api.Table table, boolean skipConfError) Get Hive table schema from deserializer.
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.
Class<?>	getHiveMetaStoreUtilsClass() Get the class of Hive's HiveMetaStoreUtils as it was split from MetaStoreUtils class in Hive 3.1.0.
Class	getHiveOutputFormatClass(Class outputFormatClz) For a given OutputFormat class, get the corresponding HiveOutputFormat class.
org.apache.hadoop.hive.ql.exec.FileSinkOperator.RecordWriter	getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jobConf, Class outputFormatClz, Class<? extends org.apache.hadoop.io.Writable> outValClz, boolean isCompressed, Properties tableProps, org.apache.hadoop.fs.Path outPath) Get Hive's FileSinkOperator.RecordWriter.
Class<?>	getMetaStoreUtilsClass() Get the class of Hive's MetaStoreUtils because its package name was changed in Hive 3.1.0.
Set<String>	getNotNullColumns(org.apache.hadoop.hive.metastore.IMetaStoreClient client, org.apache.hadoop.conf.Configuration conf, String dbName, String tableName) Get the set of columns that have NOT NULL constraints.
Optional<org.apache.flink.table.api.constraints.UniqueConstraint>	getPrimaryKey(org.apache.hadoop.hive.metastore.IMetaStoreClient client, String dbName, String tableName, byte requiredTrait) Get the primary key of a Hive table and convert it to a UniqueConstraint.
Class<?>	getTimestampDataTypeClass() Hive Timestamp data type class was changed in Hive 3.1.0.
List<String>	getViews(org.apache.hadoop.hive.metastore.IMetaStoreClient client, String databaseName) Get a list of views in the given database from the given Hive Metastore client.
org.apache.hadoop.io.Writable	hivePrimitiveToWritable(Object value) Converts a Hive primitive java object to corresponding Writable 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.
java.time.LocalDate	toFlinkDate(Object hiveDate) Converts a hive date instance to LocalDate which is expected by DataFormatConverter.
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.
java.time.LocalDateTime	toFlinkTimestamp(Object hiveTimestamp) Converts a hive timestamp instance to LocalDateTime which is expected by DataFormatConverter.
Object	toHiveDate(Object flinkDate) Converts a Flink date instance to what's expected by Hive.
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.
Object	toHiveTimestamp(Object flinkTimestamp) Converts a Flink timestamp instance to what's expected by Hive.

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

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

构造器详细资料

HiveShimV100

public HiveShimV100()

方法详细资料

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

参数:

hiveConf - HiveConf instance

返回:

an IMetaStoreClient instance

getViews

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

从接口复制的说明: HiveShim

Get a list of views in the given database from the given Hive Metastore client.

指定者:

getViews 在接口中 HiveShim

参数:

client - Hive Metastore client

databaseName - the name of the database

返回:

A list of names of the views

抛出:

org.apache.hadoop.hive.metastore.api.UnknownDBException - if the database doesn't exist

org.apache.thrift.TException - for any other generic exceptions caused by Thrift

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

参数:

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

alterPartition

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

指定者:

alterPartition 在接口中 HiveShim

抛出:

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

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

org.apache.thrift.TException

createUDAFParameterInfo

public org.apache.hadoop.hive.ql.udf.generic.SimpleGenericUDAFParameterInfo createUDAFParameterInfo(org.apache.hadoop.hive.serde2.objectinspector.ObjectInspector[] params,
                                                                                                    boolean isWindowing,
                                                                                                    boolean distinct,
                                                                                                    boolean allColumns)

从接口复制的说明: HiveShim

Creates SimpleGenericUDAFParameterInfo.

指定者:

createUDAFParameterInfo 在接口中 HiveShim

getMetaStoreUtilsClass

public Class<?> getMetaStoreUtilsClass()

从接口复制的说明: HiveShim

Get the class of Hive's MetaStoreUtils because its package name was changed in Hive 3.1.0.

指定者:

getMetaStoreUtilsClass 在接口中 HiveShim

返回:

MetaStoreUtils class

getHiveMetaStoreUtilsClass

public Class<?> getHiveMetaStoreUtilsClass()

从接口复制的说明: HiveShim

Get the class of Hive's HiveMetaStoreUtils as it was split from MetaStoreUtils class in Hive 3.1.0.

指定者:

getHiveMetaStoreUtilsClass 在接口中 HiveShim

返回:

HiveMetaStoreUtils class

getDateDataTypeClass

public Class<?> getDateDataTypeClass()

从接口复制的说明: HiveShim

Hive Date data type class was changed in Hive 3.1.0.

指定者:

getDateDataTypeClass 在接口中 HiveShim

返回:

Hive's Date class

getTimestampDataTypeClass

public Class<?> getTimestampDataTypeClass()

从接口复制的说明: HiveShim

Hive Timestamp data type class was changed in Hive 3.1.0.

指定者:

getTimestampDataTypeClass 在接口中 HiveShim

返回:

Hive's Timestamp class

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

isDateStats

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

从接口复制的说明: HiveShim

Whether a Hive ColumnStatisticsData is for DATE columns.

指定者:

isDateStats 在接口中 HiveShim

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

getHiveRecordWriter

public org.apache.hadoop.hive.ql.exec.FileSinkOperator.RecordWriter getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jobConf,
                                                                                        Class outputFormatClz,
                                                                                        Class<? extends org.apache.hadoop.io.Writable> outValClz,
                                                                                        boolean isCompressed,
                                                                                        Properties tableProps,
                                                                                        org.apache.hadoop.fs.Path outPath)

从接口复制的说明: HiveShim

Get Hive's FileSinkOperator.RecordWriter.

指定者:

getHiveRecordWriter 在接口中 HiveShim

getHiveOutputFormatClass

public Class getHiveOutputFormatClass(Class outputFormatClz)

从接口复制的说明: HiveShim

For a given OutputFormat class, get the corresponding HiveOutputFormat class.

指定者:

getHiveOutputFormatClass 在接口中 HiveShim

getFieldsFromDeserializer

public List<org.apache.hadoop.hive.metastore.api.FieldSchema> getFieldsFromDeserializer(org.apache.hadoop.conf.Configuration conf,
                                                                                        org.apache.hadoop.hive.metastore.api.Table table,
                                                                                        boolean skipConfError)

从接口复制的说明: HiveShim

Get Hive table schema from deserializer.

指定者:

getFieldsFromDeserializer 在接口中 HiveShim

listBuiltInFunctions

public Set<String> listBuiltInFunctions()

从接口复制的说明: HiveShim

List names of all built-in functions.

指定者:

listBuiltInFunctions 在接口中 HiveShim

getBuiltInFunctionInfo

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

从接口复制的说明: HiveShim

Get a Hive built-in function by name.

指定者:

getBuiltInFunctionInfo 在接口中 HiveShim

getNotNullColumns

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

从接口复制的说明: HiveShim

Get the set of columns that have NOT NULL constraints.

指定者:

getNotNullColumns 在接口中 HiveShim

getPrimaryKey

public Optional<org.apache.flink.table.api.constraints.UniqueConstraint> getPrimaryKey(org.apache.hadoop.hive.metastore.IMetaStoreClient client,
                                                                                       String dbName,
                                                                                       String tableName,
                                                                                       byte requiredTrait)

从接口复制的说明: HiveShim

Get the primary key of a Hive table and convert it to a UniqueConstraint. Return empty if the table doesn't have a primary key, or the constraint doesn't satisfy the desired trait, e.g. RELY.

指定者:

getPrimaryKey 在接口中 HiveShim

toHiveTimestamp

public Object toHiveTimestamp(Object flinkTimestamp)

从接口复制的说明: HiveShim

Converts a Flink timestamp instance to what's expected by Hive.

指定者:

toHiveTimestamp 在接口中 HiveShim

toFlinkTimestamp

public java.time.LocalDateTime toFlinkTimestamp(Object hiveTimestamp)

从接口复制的说明: HiveShim

Converts a hive timestamp instance to LocalDateTime which is expected by DataFormatConverter.

指定者:

toFlinkTimestamp 在接口中 HiveShim

toHiveDate

public Object toHiveDate(Object flinkDate)

从接口复制的说明: HiveShim

Converts a Flink date instance to what's expected by Hive.

指定者:

toHiveDate 在接口中 HiveShim

toFlinkDate

public java.time.LocalDate toFlinkDate(Object hiveDate)

从接口复制的说明: HiveShim

Converts a hive date instance to LocalDate which is expected by DataFormatConverter.

指定者:

toFlinkDate 在接口中 HiveShim

hivePrimitiveToWritable

public org.apache.hadoop.io.Writable hivePrimitiveToWritable(Object value)

从接口复制的说明: HiveShim

Converts a Hive primitive java object to corresponding Writable object.

指定者:

hivePrimitiveToWritable 在接口中 HiveShim