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

Field Summary

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

holdDDLTime, inheritTableSpecs, isAcid, isSkewedStoreAsSubdir

Constructor Summary

Constructors

Constructor and Description
HiveShimV200()

Method Summary

Modifier and Type	Method and Description
BulkWriter.Factory<RowData>	createOrcBulkWriterFactory(org.apache.hadoop.conf.Configuration conf, String schema, LogicalType[] fieldTypes) Create orc BulkWriter.Factory for different hive versions.
org.apache.hadoop.hive.metastore.IMetaStoreClient	getHiveMetastoreClient(HiveConf hiveConf) Create a Hive Metastore client based on the given HiveConf object.
void	loadPartition(org.apache.hadoop.hive.ql.metadata.Hive hive, org.apache.hadoop.fs.Path loadPath, String tableName, Map<String,String> partSpec, boolean isSkewedStoreAsSubdir, boolean replace, boolean isSrcLocal)
void	loadTable(org.apache.hadoop.hive.ql.metadata.Hive hive, org.apache.hadoop.fs.Path loadPath, String tableName, boolean replace, boolean isSrcLocal)

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

alterTable, 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

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

HiveShimV200

public HiveShimV200()

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 HiveShimV120

Parameters:

hiveConf - HiveConf instance

Returns:

an IMetaStoreClient instance

createOrcBulkWriterFactory

public BulkWriter.Factory<RowData> createOrcBulkWriterFactory(org.apache.hadoop.conf.Configuration conf,
                                                              String schema,
                                                              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

loadTable

public void loadTable(org.apache.hadoop.hive.ql.metadata.Hive hive,
                      org.apache.hadoop.fs.Path loadPath,
                      String tableName,
                      boolean replace,
                      boolean isSrcLocal)

Specified by:

loadTable in interface HiveShim

Overrides:

loadTable in class HiveShimV100

loadPartition

public void loadPartition(org.apache.hadoop.hive.ql.metadata.Hive hive,
                          org.apache.hadoop.fs.Path loadPath,
                          String tableName,
                          Map<String,String> partSpec,
                          boolean isSkewedStoreAsSubdir,
                          boolean replace,
                          boolean isSrcLocal)

Specified by:

loadPartition in interface HiveShim

Overrides:

loadPartition in class HiveShimV100