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

Class HiveShimV200

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

All Implemented Interfaces:

Serializable, HiveShim

Direct Known Subclasses:

HiveShimV201

public class HiveShimV200
extends HiveShimV122

Shim for Hive version 2.0.0.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HiveShimV200()

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.common.serialization.BulkWriter.Factory<org.apache.flink.table.data.RowData>	createOrcBulkWriterFactory(org.apache.hadoop.conf.Configuration conf, String schema, org.apache.flink.table.types.logical.LogicalType[] fieldTypes) Create orc BulkWriter.Factory for different hive versions.
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.

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

alterTable, getBuiltInFunctionInfo, isDateStats, listBuiltInFunctions, 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

alterPartition, createTableWithConstraints, createUDAFParameterInfo, getDateDataTypeClass, getHiveMetaStoreUtilsClass, getMetaStoreUtilsClass, getNotNullColumns, getPrimaryKey, getTimestampDataTypeClass, getViews, 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

HiveShimV200

public HiveShimV200()

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 HiveShimV120

Parameters:

hiveConf - HiveConf instance

Returns:

an IMetaStoreClient instance

createOrcBulkWriterFactory

public org.apache.flink.api.common.serialization.BulkWriter.Factory<org.apache.flink.table.data.RowData> createOrcBulkWriterFactory(org.apache.hadoop.conf.Configuration conf,
                                                                                                                                    String schema,
                                                                                                                                    org.apache.flink.table.types.logical.LogicalType[] fieldTypes)

Description copied from interface: HiveShim

Create orc BulkWriter.Factory for different hive versions.

Specified by:

createOrcBulkWriterFactory in interface HiveShim

Overrides:

createOrcBulkWriterFactory in class HiveShimV100