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

Class HiveShimV210

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

All Implemented Interfaces:

Serializable, HiveShim

Direct Known Subclasses:

HiveShimV211

public class HiveShimV210
extends HiveShimV201

Shim for Hive version 2.1.0.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	hasFollowingStatsTask

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

holdDDLTime, inheritTableSpecs, isAcid, isSkewedStoreAsSubdir

Constructor Summary

Constructors

Constructor and Description
HiveShimV210()

Method Summary

Modifier and Type	Method and Description
void	alterPartition(org.apache.hadoop.hive.metastore.IMetaStoreClient client, String databaseName, String tableName, org.apache.hadoop.hive.metastore.api.Partition partition)
void	createTableWithConstraints(org.apache.hadoop.hive.metastore.IMetaStoreClient client, org.apache.hadoop.hive.metastore.api.Table table, org.apache.hadoop.conf.Configuration conf, UniqueConstraint pk, List<Byte> pkTraits, List<String> notNullCols, List<Byte> nnTraits) Creates a table with PK and NOT NULL constraints.
Optional<UniqueConstraint>	getPrimaryKey(org.apache.hadoop.hive.metastore.IMetaStoreClient client, String dbName, String tableName, byte requiredTrait) Get the primary key of a Hive table and convert it to a UniqueConstraint.
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.HiveShimV200

createOrcBulkWriterFactory, getHiveMetastoreClient

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

createUDAFParameterInfo, getBuiltInFunctionInfo, getDateDataTypeClass, getDateWritableClass, getHiveMetaStoreUtilsClass, getMetaStoreUtilsClass, getNotNullColumns, 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

Field Detail

hasFollowingStatsTask

protected final boolean hasFollowingStatsTask

See Also:

Constant Field Values

Constructor Detail

HiveShimV210

public HiveShimV210()

Method Detail

alterPartition

public void alterPartition(org.apache.hadoop.hive.metastore.IMetaStoreClient client,
                           String databaseName,
                           String tableName,
                           org.apache.hadoop.hive.metastore.api.Partition partition)
                    throws org.apache.hadoop.hive.metastore.api.InvalidOperationException,
                           org.apache.hadoop.hive.metastore.api.MetaException,
                           org.apache.thrift.TException

Specified by:

alterPartition in interface HiveShim

Overrides:

alterPartition in class HiveShimV100

Throws:

org.apache.hadoop.hive.metastore.api.InvalidOperationException

org.apache.hadoop.hive.metastore.api.MetaException

org.apache.thrift.TException

getPrimaryKey

public Optional<UniqueConstraint> getPrimaryKey(org.apache.hadoop.hive.metastore.IMetaStoreClient client,
                                                String dbName,
                                                String tableName,
                                                byte requiredTrait)

Description copied from interface: HiveShim

Get the primary key of a Hive table and convert it to a UniqueConstraint. Return empty if the table doesn't have a primary key, or the constraint doesn't satisfy the desired trait, e.g. RELY.

Specified by:

getPrimaryKey in interface HiveShim

Overrides:

getPrimaryKey in class HiveShimV100

createTableWithConstraints

public void createTableWithConstraints(org.apache.hadoop.hive.metastore.IMetaStoreClient client,
                                       org.apache.hadoop.hive.metastore.api.Table table,
                                       org.apache.hadoop.conf.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 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 HiveShimV200

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 HiveShimV200