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

Class 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

All Implemented Interfaces:

Serializable, HiveShim

Direct Known Subclasses:

HiveShimV121

public class HiveShimV120
extends HiveShimV111

Shim for Hive version 1.2.0.

See Also:

Serialized Form

Field Summary

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

holdDDLTime, inheritTableSpecs, isAcid, isSkewedStoreAsSubdir

Constructor Summary

Constructors

Constructor and Description
HiveShimV120()

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.metastore.IMetaStoreClient	getHiveMetastoreClient(HiveConf hiveConf) Create a Hive Metastore client based on the given HiveConf object.
org.apache.hadoop.hive.serde2.typeinfo.PrimitiveTypeInfo	getIntervalDayTimeTypeInfo()
org.apache.hadoop.hive.serde2.typeinfo.PrimitiveTypeInfo	getIntervalYearMonthTypeInfo()
boolean	isDateStats(org.apache.hadoop.hive.metastore.api.ColumnStatisticsData colStatsData) Whether a Hive ColumnStatisticsData is for DATE columns.
boolean	isIntervalDayTimeType(org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector.PrimitiveCategory primitiveCategory)
boolean	isIntervalYearMonthType(org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector.PrimitiveCategory primitiveCategory)
Set<String>	listBuiltInFunctions() List names of all built-in functions.
void	registerTemporaryFunction(String funcName, Class funcClass)
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(CatalogColumnStatisticsDataDate flinkDateColStats) Generate Hive ColumnStatisticsData from Flink CatalogColumnStatisticsDataDate for DATE columns.

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

alterPartition, createOrcBulkWriterFactory, createTableWithConstraints, createUDAFParameterInfo, getBuiltInFunctionInfo, getDateDataTypeClass, getDateWritableClass, getHiveMetaStoreUtilsClass, getMetaStoreUtilsClass, getNotNullColumns, getPrimaryKey, getTimestampDataTypeClass, getTimestampWritableClass, getViews, hivePrimitiveToWritable, loadPartition, loadTable, toFlinkDate, toFlinkTimestamp, toHiveDate, toHiveTimestamp

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.catalog.hive.client.HiveShim

isMaterializedView

Constructor Detail

HiveShimV120

public HiveShimV120()

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 HiveShimV100

Parameters:

hiveConf - HiveConf instance

Returns:

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

Description copied from interface: HiveShim

Alters a Hive table.

Specified by:

alterTable in interface HiveShim

Overrides:

alterTable in class HiveShimV100

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

toHiveDateColStats

public org.apache.hadoop.hive.metastore.api.ColumnStatisticsData toHiveDateColStats(CatalogColumnStatisticsDataDate flinkDateColStats)

Description copied from interface: HiveShim

Generate Hive ColumnStatisticsData from Flink CatalogColumnStatisticsDataDate for DATE columns.

Specified by:

toHiveDateColStats in interface HiveShim

Overrides:

toHiveDateColStats in class HiveShimV100

isDateStats

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

Description copied from interface: HiveShim

Whether a Hive ColumnStatisticsData is for DATE columns.

Specified by:

isDateStats in interface HiveShim

Overrides:

isDateStats in class HiveShimV100

toFlinkDateColStats

public CatalogColumnStatisticsDataDate toFlinkDateColStats(org.apache.hadoop.hive.metastore.api.ColumnStatisticsData hiveDateColStats)

Description copied from interface: HiveShim

Generate Flink CatalogColumnStatisticsDataDate from Hive ColumnStatisticsData for DATE columns.

Specified by:

toFlinkDateColStats in interface HiveShim

Overrides:

toFlinkDateColStats in class HiveShimV100

listBuiltInFunctions

public Set<String> listBuiltInFunctions()

Description copied from interface: HiveShim

List names of all built-in functions.

Specified by:

listBuiltInFunctions in interface HiveShim

Overrides:

listBuiltInFunctions in class HiveShimV100

getIntervalYearMonthTypeInfo

public org.apache.hadoop.hive.serde2.typeinfo.PrimitiveTypeInfo getIntervalYearMonthTypeInfo()

getIntervalDayTimeTypeInfo

public org.apache.hadoop.hive.serde2.typeinfo.PrimitiveTypeInfo getIntervalDayTimeTypeInfo()

isIntervalYearMonthType

public boolean isIntervalYearMonthType(org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector.PrimitiveCategory primitiveCategory)

isIntervalDayTimeType

public boolean isIntervalDayTimeType(org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector.PrimitiveCategory primitiveCategory)

registerTemporaryFunction

public void registerTemporaryFunction(String funcName,
                                      Class funcClass)

Specified by:

registerTemporaryFunction in interface HiveShim

Overrides:

registerTemporaryFunction in class HiveShimV100