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

类 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

所有已实现的接口:

Serializable, HiveShim

直接已知子类:

HiveShimV211

public class HiveShimV210
extends HiveShimV201

Shim for Hive version 2.1.0.

另请参阅:

序列化表格

构造器概要

构造器

构造器和说明
HiveShimV210()

方法概要

限定符和类型	方法和说明
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, org.apache.flink.table.api.constraints.UniqueConstraint pk, List<Byte> pkTraits, List<String> notNullCols, List<Byte> nnTraits) Creates a table with PK and NOT NULL constraints.
Optional<org.apache.flink.table.api.constraints.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.

从类继承的方法 org.apache.flink.table.catalog.hive.client.HiveShimV200

createOrcBulkWriterFactory, getHiveMetastoreClient

从类继承的方法 org.apache.flink.table.catalog.hive.client.HiveShimV120

alterTable, getBuiltInFunctionInfo, isDateStats, listBuiltInFunctions, toFlinkDateColStats, toHiveDateColStats

从类继承的方法 org.apache.flink.table.catalog.hive.client.HiveShimV110

getFieldsFromDeserializer, getHiveOutputFormatClass, getHiveRecordWriter

从类继承的方法 org.apache.flink.table.catalog.hive.client.HiveShimV100

createUDAFParameterInfo, getDateDataTypeClass, getHiveMetaStoreUtilsClass, getMetaStoreUtilsClass, getNotNullColumns, getTimestampDataTypeClass, getViews, hivePrimitiveToWritable, toFlinkDate, toFlinkTimestamp, toHiveDate, toHiveTimestamp

从类继承的方法 java.lang.Object

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

构造器详细资料

HiveShimV210

public HiveShimV210()

方法详细资料

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

指定者:

alterPartition 在接口中 HiveShim

覆盖:

alterPartition 在类中 HiveShimV100

抛出:

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

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

org.apache.thrift.TException

getPrimaryKey

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

从接口复制的说明: 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.

指定者:

getPrimaryKey 在接口中 HiveShim

覆盖:

getPrimaryKey 在类中 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,
                                       org.apache.flink.table.api.constraints.UniqueConstraint pk,
                                       List<Byte> pkTraits,
                                       List<String> notNullCols,
                                       List<Byte> nnTraits)

从接口复制的说明: HiveShim

Creates a table with PK and NOT NULL constraints.

指定者:

createTableWithConstraints 在接口中 HiveShim

覆盖:

createTableWithConstraints 在类中 HiveShimV100