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

Class HiveShimV310

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

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

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

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

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

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

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

All Implemented Interfaces:

Serializable, HiveShim

Direct Known Subclasses:

HiveShimV311

public class HiveShimV310
extends HiveShimV235

Shim for Hive version 3.1.0.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HiveShimV310()

Method Summary

Modifier and Type	Method and Description
void	createTableWithConstraints(org.apache.hadoop.hive.metastore.IMetaStoreClient client, org.apache.hadoop.hive.metastore.api.Table table, Configuration conf, UniqueConstraint pk, List<Byte> pkTraits, List<String> notNullCols, List<Byte> nnTraits) Creates a table with PK and NOT NULL constraints.
Class<?>	getDateDataTypeClass() Hive Date data type class was changed in Hive 3.1.0.
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<?>	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, Configuration conf, String dbName, String tableName) Get the set of columns that have NOT NULL constraints.
Class<?>	getTimestampDataTypeClass() Hive Timestamp data type class was changed in Hive 3.1.0.
org.apache.hadoop.io.Writable	hivePrimitiveToWritable(Object value) Converts a Hive primitive java object to corresponding Writable object.
java.time.LocalDate	toFlinkDate(Object hiveDate) Converts a hive date instance to LocalDate which is expected by DataFormatConverter.
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.
Object	toHiveTimestamp(Object flinkTimestamp) Converts a Flink timestamp instance to what's expected by Hive.

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

alterTable, createUDAFParameterInfo, getViews, isMaterializedView

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

alterPartition, getPrimaryKey

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

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveShimV310

public HiveShimV310()

Method Detail

getHiveMetastoreClient

public org.apache.hadoop.hive.metastore.IMetaStoreClient getHiveMetastoreClient(org.apache.hadoop.hive.conf.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 HiveShimV230

Parameters:

hiveConf - HiveConf instance

Returns:

an IMetaStoreClient instance

getMetaStoreUtilsClass

public Class<?> getMetaStoreUtilsClass()

Description copied from interface: HiveShim

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

Specified by:

getMetaStoreUtilsClass in interface HiveShim

Overrides:

getMetaStoreUtilsClass in class HiveShimV100

Returns:

MetaStoreUtils class

getHiveMetaStoreUtilsClass

public Class<?> getHiveMetaStoreUtilsClass()

Description copied from interface: HiveShim

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

Specified by:

getHiveMetaStoreUtilsClass in interface HiveShim

Overrides:

getHiveMetaStoreUtilsClass in class HiveShimV100

Returns:

HiveMetaStoreUtils class

getDateDataTypeClass

public Class<?> getDateDataTypeClass()

Description copied from interface: HiveShim

Hive Date data type class was changed in Hive 3.1.0.

Specified by:

getDateDataTypeClass in interface HiveShim

Overrides:

getDateDataTypeClass in class HiveShimV100

Returns:

Hive's Date class

getTimestampDataTypeClass

public Class<?> getTimestampDataTypeClass()

Description copied from interface: HiveShim

Hive Timestamp data type class was changed in Hive 3.1.0.

Specified by:

getTimestampDataTypeClass in interface HiveShim

Overrides:

getTimestampDataTypeClass in class HiveShimV100

Returns:

Hive's Timestamp class

getNotNullColumns

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

Description copied from interface: HiveShim

Get the set of columns that have NOT NULL constraints.

Specified by:

getNotNullColumns in interface HiveShim

Overrides:

getNotNullColumns in class HiveShimV100

toHiveTimestamp

public Object toHiveTimestamp(Object flinkTimestamp)

Description copied from interface: HiveShim

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

Specified by:

toHiveTimestamp in interface HiveShim

Overrides:

toHiveTimestamp in class HiveShimV100

toFlinkTimestamp

public java.time.LocalDateTime toFlinkTimestamp(Object hiveTimestamp)

Description copied from interface: HiveShim

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

Specified by:

toFlinkTimestamp in interface HiveShim

Overrides:

toFlinkTimestamp in class HiveShimV100

toHiveDate

public Object toHiveDate(Object flinkDate)

Description copied from interface: HiveShim

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

Specified by:

toHiveDate in interface HiveShim

Overrides:

toHiveDate in class HiveShimV100

toFlinkDate

public java.time.LocalDate toFlinkDate(Object hiveDate)

Description copied from interface: HiveShim

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

Specified by:

toFlinkDate in interface HiveShim

Overrides:

toFlinkDate in class HiveShimV100

hivePrimitiveToWritable

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

Description copied from interface: HiveShim

Converts a Hive primitive java object to corresponding Writable object.

Specified by:

hivePrimitiveToWritable in interface HiveShim

Overrides:

hivePrimitiveToWritable in class HiveShimV100

createTableWithConstraints

public void createTableWithConstraints(org.apache.hadoop.hive.metastore.IMetaStoreClient client,
                                       org.apache.hadoop.hive.metastore.api.Table table,
                                       Configuration conf,
                                       UniqueConstraint pk,
                                       List<Byte> pkTraits,
                                       List<String> notNullCols,
                                       List<Byte> nnTraits)

Description copied from interface: HiveShim

Creates a table with PK and NOT NULL constraints.

Specified by:

createTableWithConstraints in interface HiveShim

Overrides:

createTableWithConstraints in class HiveShimV210