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

Class 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

All Implemented Interfaces:

Serializable, HiveShim

Direct Known Subclasses:

HiveShimV231

public class HiveShimV230
extends HiveShimV220

Shim for Hive version 2.3.0.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.table.catalog.hive.client.HiveShimV210

hasFollowingStatsTask

Fields inherited from class org.apache.flink.table.catalog.hive.client.HiveShimV100

holdDDLTime, inheritTableSpecs, isAcid, isSkewedStoreAsSubdir

Constructor Summary

Constructors

Constructor and Description
HiveShimV230()

Method Summary

Modifier and Type	Method and Description
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(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.
boolean	isMaterializedView(org.apache.hadoop.hive.ql.metadata.Table table) Checks whether a hive table is a materialized view.

Methods inherited from class org.apache.flink.table.catalog.hive.client.HiveShimV210

alterPartition, createTableWithConstraints, getPrimaryKey, loadPartition, loadTable

Methods inherited from class org.apache.flink.table.catalog.hive.client.HiveShimV200

createOrcBulkWriterFactory

Methods inherited from class org.apache.flink.table.catalog.hive.client.HiveShimV120

getIntervalDayTimeTypeInfo, getIntervalYearMonthTypeInfo, isDateStats, isIntervalDayTimeType, isIntervalYearMonthType, listBuiltInFunctions, registerTemporaryFunction, toFlinkDateColStats, toHiveDateColStats

Methods inherited from class org.apache.flink.table.catalog.hive.client.HiveShimV110

getFieldsFromDeserializer, getHiveOutputFormatClass, getHiveRecordWriter

Methods inherited from class org.apache.flink.table.catalog.hive.client.HiveShimV100

getBuiltInFunctionInfo, getDateDataTypeClass, getDateWritableClass, getHiveMetaStoreUtilsClass, getMetaStoreUtilsClass, getNotNullColumns, getTimestampDataTypeClass, getTimestampWritableClass, hivePrimitiveToWritable, toFlinkDate, toFlinkTimestamp, toHiveDate, toHiveTimestamp

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveShimV230

public HiveShimV230()

Method Detail

getHiveMetastoreClient

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

Description copied from interface: HiveShim

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

Specified by:

getHiveMetastoreClient in interface HiveShim

Overrides:

getHiveMetastoreClient in class HiveShimV200

Parameters:

hiveConf - HiveConf instance

Returns:

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

Description copied from interface: HiveShim

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

Specified by:

getViews in interface HiveShim

Overrides:

getViews in class HiveShimV100

Parameters:

client - Hive Metastore client

databaseName - the name of the database

Returns:

A list of names of the views

Throws:

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

Description copied from interface: HiveShim

Alters a Hive table.

Specified by:

alterTable in interface HiveShim

Overrides:

alterTable in class HiveShimV120

Parameters:

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

Throws:

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)

Description copied from interface: HiveShim

Creates SimpleGenericUDAFParameterInfo.

Specified by:

createUDAFParameterInfo in interface HiveShim

Overrides:

createUDAFParameterInfo in class HiveShimV100

isMaterializedView

public boolean isMaterializedView(org.apache.hadoop.hive.ql.metadata.Table table)

Description copied from interface: HiveShim

Checks whether a hive table is a materialized view.