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

类 HiveShimV230

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

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

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

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

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

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

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

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

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

所有已实现的接口:

Serializable, HiveShim

直接已知子类:

HiveShimV231

public class HiveShimV230
extends HiveShimV220

Shim for Hive version 2.3.0.

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
HiveShimV230()

方法概要

限定符和类型	方法和说明
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.
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.
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.flink.table.catalog.hive.client.HiveShimV210

alterPartition, getPrimaryKey

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

getBuiltInFunctionInfo, isDateStats, listBuiltInFunctions, toFlinkDateColStats, toHiveDateColStats

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

getFieldsFromDeserializer, getHiveOutputFormatClass, getHiveRecordWriter

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

getDateDataTypeClass, getHiveMetaStoreUtilsClass, getMetaStoreUtilsClass, getNotNullColumns, getTimestampDataTypeClass, hivePrimitiveToWritable, toFlinkDate, toFlinkTimestamp, toHiveDate, toHiveTimestamp

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

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

构造器详细资料

HiveShimV230

public HiveShimV230()

方法详细资料

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 在类中 HiveShimV200

参数:

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

覆盖:

getViews 在类中 HiveShimV100

参数:

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

覆盖:

alterTable 在类中 HiveShimV120

参数:

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

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

覆盖:

createUDAFParameterInfo 在类中 HiveShimV100