public class HiveShimV310 extends HiveShimV235
| 构造器和说明 |
|---|
HiveShimV310() |
| 限定符和类型 | 方法和说明 |
|---|---|
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,
org.apache.hadoop.conf.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.
|
alterTable, createUDAFParameterInfo, getViewsalterPartition, getPrimaryKeygetBuiltInFunctionInfo, isDateStats, listBuiltInFunctions, toFlinkDateColStats, toHiveDateColStatsgetFieldsFromDeserializer, getHiveOutputFormatClass, getHiveRecordWriterpublic org.apache.hadoop.hive.metastore.IMetaStoreClient getHiveMetastoreClient(org.apache.hadoop.hive.conf.HiveConf hiveConf)
HiveShimgetHiveMetastoreClient 在接口中 HiveShimgetHiveMetastoreClient 在类中 HiveShimV230hiveConf - HiveConf instancepublic Class<?> getMetaStoreUtilsClass()
HiveShimgetMetaStoreUtilsClass 在接口中 HiveShimgetMetaStoreUtilsClass 在类中 HiveShimV100public Class<?> getHiveMetaStoreUtilsClass()
HiveShimgetHiveMetaStoreUtilsClass 在接口中 HiveShimgetHiveMetaStoreUtilsClass 在类中 HiveShimV100public Class<?> getDateDataTypeClass()
HiveShimgetDateDataTypeClass 在接口中 HiveShimgetDateDataTypeClass 在类中 HiveShimV100public Class<?> getTimestampDataTypeClass()
HiveShimgetTimestampDataTypeClass 在接口中 HiveShimgetTimestampDataTypeClass 在类中 HiveShimV100public Set<String> getNotNullColumns(org.apache.hadoop.hive.metastore.IMetaStoreClient client, org.apache.hadoop.conf.Configuration conf, String dbName, String tableName)
HiveShimgetNotNullColumns 在接口中 HiveShimgetNotNullColumns 在类中 HiveShimV100public Object toHiveTimestamp(Object flinkTimestamp)
HiveShimtoHiveTimestamp 在接口中 HiveShimtoHiveTimestamp 在类中 HiveShimV100public java.time.LocalDateTime toFlinkTimestamp(Object hiveTimestamp)
HiveShimtoFlinkTimestamp 在接口中 HiveShimtoFlinkTimestamp 在类中 HiveShimV100public Object toHiveDate(Object flinkDate)
HiveShimtoHiveDate 在接口中 HiveShimtoHiveDate 在类中 HiveShimV100public java.time.LocalDate toFlinkDate(Object hiveDate)
HiveShimtoFlinkDate 在接口中 HiveShimtoFlinkDate 在类中 HiveShimV100public org.apache.hadoop.io.Writable hivePrimitiveToWritable(Object value)
HiveShimhivePrimitiveToWritable 在接口中 HiveShimhivePrimitiveToWritable 在类中 HiveShimV100Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.